Versions in this module Expand all Collapse all v3 v3.1.0 May 2, 2025 Changes in this version + var ErrWorkflowContextNotFound = errors.New("workflow context not found") + func WithWorkflowContext(parent context.Context, wfCtx WorkflowContext) context.Context + type StatusPhase string + const CancelledStatus + const CompletedStatus + const FaultedStatus + const PendingStatus + const RunningStatus + const SuspendedStatus + const WaitingStatus + func (s StatusPhase) String() string + type StatusPhaseLog struct + Status StatusPhase + Timestamp int64 + func NewStatusPhaseLog(status StatusPhase) StatusPhaseLog + type WorkflowContext interface + AddLocalExprVars func(vars map[string]interface{}) + ClearTaskContext func() + Clone func() WorkflowContext + GetInput func() interface{} + GetInstanceCtx func() interface{} + GetOutput func() interface{} + GetOutputAsMap func() map[string]interface{} + GetTaskReference func() string + GetVars func() map[string]interface{} + RemoveLocalExprVars func(keys ...string) + SetInput func(input interface{}) + SetInstanceCtx func(value interface{}) + SetLocalExprVars func(vars map[string]interface{}) + SetOutput func(output interface{}) + SetRawInput func(input interface{}) + SetStartedAt func(t time.Time) + SetStatus func(status StatusPhase) + SetTaskDef func(task model.Task) error + SetTaskName func(name string) + SetTaskRawInput func(input interface{}) + SetTaskRawOutput func(output interface{}) + SetTaskReference func(ref string) + SetTaskStartedAt func(startedAt time.Time) + SetTaskStatus func(task string, status StatusPhase) + func GetWorkflowContext(ctx context.Context) (WorkflowContext, error) + func NewWorkflowContext(workflow *model.Workflow) (WorkflowContext, error)
Go to main page