Golang kernel.IEvtCtx类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/sbinet/go-gaudi/pkg/gaudi/kernel.IEvtCtx类的典型用法代码示例。如果您正苦于以下问题：Golang IEvtCtx类的具体用法？Golang IEvtCtx怎么用？Golang IEvtCtx使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了IEvtCtx类的5个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: Execute

func (self *alg_adder) Execute(ctx kernel.IEvtCtx) kernel.Error {
	self.MsgDebug("== execute == [%v]\n", ctx.Idx())

	njets := 1 + ctx.Idx()
	val := self.val + 1
	store := self.EvtStore(ctx)

	if store.Has("njets") {
		njets += store.Get("njets").(int)
	}
	store.Put("njets", njets)

	if store.Has("ptjets") {
		val += store.Get("ptjets").(float64)
	}
	store.Put("ptjets", val)

	cnt := &simple_counter{0}
	if store.Has(self.cnt_key) {
		cnt = store.Get(self.cnt_key).(*simple_counter)
	}
	cnt.Cnt += 1
	store.Put(self.cnt_key, cnt)
	return kernel.StatusCode(0)
}

开发者ID:sbinet，项目名称:go-gaudi，代码行数:25，代码来源:pkg2.go

示例2: Store

func (self *datastoresvc) Store(ctx kernel.IEvtCtx) kernel.IDataStore {
	store := ctx.Store()
	n := self.CompName()
	if _, ok := store[n]; !ok {
		dstore := make(kernel.DataStore)
		//dstore := make(map[string]chan interface{})
		store[n] = dstore
	}

	dstore := store[n].(kernel.DataStore)
	//dstore := store[n].(map[string]chan interface{})
	if dstore != nil {
		return &datastore{dstore}
	}

	return nil
}

开发者ID:sbinet，项目名称:go-gaudi，代码行数:17，代码来源:datastore.go

示例3: Execute

func (self *json_outstream) Execute(ctx kernel.IEvtCtx) kernel.Error {
	self.MsgDebug("== execute ==\n")
	store := self.EvtStore(ctx)
	if store == nil {
		self.MsgError("could not retrieve evt-store\n")
	}

	hdr_offset := 1

	val := make([]interface{}, len(self.item_names)+hdr_offset)
	val[0] = ctx.Idx()

	for i, k := range self.item_names {
		val[i+hdr_offset] = store.Get(k)
	}

	return self.handle.Write(val)
}

开发者ID:sbinet，项目名称:go-gaudi，代码行数:18，代码来源:outstream.go

示例4: ExecuteEvent

func (self *evtproc) ExecuteEvent(ictx kernel.IEvtCtx) kernel.Error {
	ctx := ictx.Idx()
	self.MsgDebug("executing event [%v]... (#algs: %v)\n", ctx, len(self.algs))
	for i, alg := range self.algs {
		self.MsgDebug("-- ctx:%03v --> [%s]...\n", ctx, alg.CompName())
		if !alg.Execute(ictx).IsSuccess() {
			self.MsgError("pb executing alg #%v (%s) for ctx:%v\n",
				i, alg.CompName(), ictx.Idx())
			return kernel.StatusCode(1)
		}
	}
	self.MsgDebug("data: %v\n", ictx.Store())
	return kernel.StatusCode(0)
}

开发者ID:sbinet，项目名称:go-gaudi，代码行数:14，代码来源:evtproc.go

示例5: Execute

func (self *alg2) Execute(ctx kernel.IEvtCtx) kernel.Error {
	self.MsgDebug("~~ execute ~~ [ctx:%v]\n", ctx.Idx())
	return kernel.StatusCode(0)
}

开发者ID:sbinet，项目名称:go-gaudi，代码行数:4，代码来源:pkg1.go

注：本文中的github.com/sbinet/go-gaudi/pkg/gaudi/kernel.IEvtCtx类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。