Documentation
¶
Index ¶
- func BuildDependencyNodeEventLists(logger *l.Logger, pCtx *ctx.MessageProcessingContext, depNodeNames []string) (map[string][]wfmodel.DependencyNodeEvent, error)
- func GetCurrentRunStatus(logger *l.Logger, pCtx *ctx.MessageProcessingContext) (wfmodel.RunStatusType, error)
- func GetNextRunCounter(logger *l.Logger, cqlSession *gocql.Session, keyspace string) (int16, error)
- func GetRunAffectedNodes(cqlSession *gocql.Session, keyspace string, runId int16) ([]string, error)
- func HarvestBatchStatusesForNode(logger *l.Logger, pCtx *ctx.MessageProcessingContext) (wfmodel.NodeBatchStatusType, error)
- func HarvestLastStatusForBatch(logger *l.Logger, pCtx *ctx.MessageProcessingContext) (wfmodel.NodeBatchStatusType, error)
- func HarvestNodeLifespans(logger *l.Logger, pCtx *ctx.MessageProcessingContext, affectingRuns []int16, ...) (wfmodel.RunNodeLifespanMap, error)
- func HarvestNodeStatusesForRun(logger *l.Logger, pCtx *ctx.MessageProcessingContext, affectedNodes []string) (wfmodel.NodeBatchStatusType, string, error)
- func HarvestRunIdsByAffectedNodes(logger *l.Logger, pCtx *ctx.MessageProcessingContext, nodeNames []string) ([]int16, map[string][]int16, error)
- func HarvestRunLifespans(logger *l.Logger, pCtx *ctx.MessageProcessingContext, runIds []int16) (wfmodel.RunLifespanMap, error)
- func SetBatchStatus(logger *l.Logger, pCtx *ctx.MessageProcessingContext, ...) error
- func SetNodeStatus(logger *l.Logger, pCtx *ctx.MessageProcessingContext, ...) (bool, error)
- func SetRunStatus(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16, ...) error
- func WriteAffectedNodes(logger *l.Logger, cqlSession *gocql.Session, keyspace string, runId int16, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildDependencyNodeEventLists ¶
func BuildDependencyNodeEventLists(logger *l.Logger, pCtx *ctx.MessageProcessingContext, depNodeNames []string) (map[string][]wfmodel.DependencyNodeEvent, error)
func GetCurrentRunStatus ¶
func GetCurrentRunStatus(logger *l.Logger, pCtx *ctx.MessageProcessingContext) (wfmodel.RunStatusType, error)
func GetNextRunCounter ¶
func GetRunAffectedNodes ¶
func HarvestBatchStatusesForNode ¶
func HarvestBatchStatusesForNode(logger *l.Logger, pCtx *ctx.MessageProcessingContext) (wfmodel.NodeBatchStatusType, error)
func HarvestLastStatusForBatch ¶
func HarvestLastStatusForBatch(logger *l.Logger, pCtx *ctx.MessageProcessingContext) (wfmodel.NodeBatchStatusType, error)
func HarvestNodeLifespans ¶
func HarvestNodeLifespans(logger *l.Logger, pCtx *ctx.MessageProcessingContext, affectingRuns []int16, affectedNodes []string) (wfmodel.RunNodeLifespanMap, error)
func HarvestNodeStatusesForRun ¶
func HarvestNodeStatusesForRun(logger *l.Logger, pCtx *ctx.MessageProcessingContext, affectedNodes []string) (wfmodel.NodeBatchStatusType, string, error)
func HarvestRunLifespans ¶
func HarvestRunLifespans(logger *l.Logger, pCtx *ctx.MessageProcessingContext, runIds []int16) (wfmodel.RunLifespanMap, error)
func SetBatchStatus ¶
func SetBatchStatus(logger *l.Logger, pCtx *ctx.MessageProcessingContext, status wfmodel.NodeBatchStatusType, comment string) error
func SetNodeStatus ¶
func SetNodeStatus(logger *l.Logger, pCtx *ctx.MessageProcessingContext, status wfmodel.NodeBatchStatusType, comment string) (bool, error)
func SetRunStatus ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.