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
Source Files
Click to show internal directories.
Click to hide internal directories.