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 ¶
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
CassandraEngine db.CassandraEngineType
}
func (*MessageProcessingContext) DbClose ¶
func (pCtx *MessageProcessingContext) DbClose()
Source Files
Click to show internal directories.
Click to hide internal directories.