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 HeartbeatCallbackFunc ¶ added in v1.2.0
type HeartbeatCallbackFunc func(string)
type MessageProcessingContext ¶
type MessageProcessingContext struct {
Msg wfmodel.Message
CqlSession *gocql.Session
Script *sc.ScriptDef
CurrentScriptNode *sc.ScriptNodeDef
ZapMsgId zapcore.Field
ZapDataKeyspace zapcore.Field
ZapRun zapcore.Field
ZapNode zapcore.Field
ZapBatchIdx zapcore.Field
ZapMsgAgeMillis zapcore.Field
CassandraEngine db.CassandraEngineType
LastHeartbeatSentTs int64
HeartbeatIntervalMillis int64
HeartbeatCallback HeartbeatCallbackFunc
}
func (*MessageProcessingContext) DbClose ¶
func (pCtx *MessageProcessingContext) DbClose()
func (*MessageProcessingContext) DbConnect ¶
func (pCtx *MessageProcessingContext) DbConnect(envConfig *env.EnvConfig) error
func (*MessageProcessingContext) SendHeartbeat ¶ added in v1.2.0
func (pCtx *MessageProcessingContext) SendHeartbeat()
Source Files
Click to show internal directories.
Click to hide internal directories.