ctx

Documentation

Overview

Package ctx contains definition of the message processing context object that holds batch message information, database connection, current script node definition and logging details.

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