ctx

Documentation

Index

• type MessageProcessingContext
  • func (pCtx *MessageProcessingContext) DbClose()
  • func (pCtx *MessageProcessingContext) DbConnect(envConfig *env.EnvConfig) error

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 (*MessageProcessingContext) DbClose

func (pCtx *MessageProcessingContext) DbClose()

func (*MessageProcessingContext) DbConnect

func (pCtx *MessageProcessingContext) DbConnect(envConfig *env.EnvConfig) error