Documentation
¶
Index ¶
Constants ¶
View Source
const ( // TODO: @joshvanl: remove CallbackChannelProperty = "dapr.callback" CreateWorkflowInstanceMethod = "CreateWorkflowInstance" AddWorkflowEventMethod = "AddWorkflowEvent" PurgeWorkflowStateMethod = "PurgeWorkflowState" WaitForRuntimeStatus = "WaitForRuntimeStatus" ForkWorkflowHistory = "ForkWorkflowHistory" RerunWorkflowInstance = "RerunWorkflowInstance" )
Variables ¶
View Source
var ( ErrExecutionAborted = errors.New("execution aborted") ErrDuplicateInvocation = errors.New("duplicate invocation") )
Functions ¶
This section is empty.
Types ¶
type ActivityScheduler ¶
type ActivityScheduler func(ctx context.Context, wi *backend.ActivityWorkItem) error
ActivityScheduler is a func interface for pushing activity work items into the durabletask backend
type RunCompleted ¶ added in v1.16.0
type RunCompleted bool
const ( RunCompletedFalse RunCompleted = false RunCompletedTrue RunCompleted = true )
type WorkflowScheduler ¶
type WorkflowScheduler func(ctx context.Context, wi *backend.OrchestrationWorkItem) error
WorkflowScheduler is a func interface for pushing workflow (orchestration) work items into the durabletask backend
Click to show internal directories.
Click to hide internal directories.