Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageProcessingContext ¶
type MessageProcessingContext struct { MsgTs int64 BatchInfo wfmodel.MessagePayloadDataBatch CqlSession *gocql.Session Script *sc.ScriptDef CurrentScriptNode *sc.ScriptNodeDef ZapDataKeyspace zapcore.Field ZapRun zapcore.Field ZapNode zapcore.Field ZapBatchIdx zapcore.Field ZapMsgAgeMillis zapcore.Field }
func NewFromBatchInfo ¶
func NewFromBatchInfo(msgTs int64, batchInfo *wfmodel.MessagePayloadDataBatch) *MessageProcessingContext
func (*MessageProcessingContext) DbClose ¶
func (pCtx *MessageProcessingContext) DbClose()
func (*MessageProcessingContext) DbConnect ¶
func (pCtx *MessageProcessingContext) DbConnect(envConfig *env.EnvConfig) error
func (*MessageProcessingContext) InitScript ¶
func (pCtx *MessageProcessingContext) InitScript(envConfig *env.EnvConfig) error
Click to show internal directories.
Click to hide internal directories.