Documentation
¶
Index ¶
Constants ¶
View Source
const ( // TODO: @joshvanl: remove CallbackChannelProperty = "dapr.callback" CreateWorkflowInstanceMethod = "CreateWorkflowInstance" AddWorkflowEventMethod = "AddWorkflowEvent" PurgeWorkflowStateMethod = "PurgeWorkflowState" RecursivePurgeWorkflowStateMethod = "RecursivePurgeWorkflowState" WaitForRuntimeStatus = "WaitForRuntimeStatus" ForkWorkflowHistory = "ForkWorkflowHistory" RerunWorkflowInstance = "RerunWorkflowInstance" ExecuteActivityMethod = "Execute" MetadataActivityReminderDueTime = "dueTime" // MetadataActivityLocalDrive certifies to the activity host that the // dispatching orchestrator has its janitor backstop armed, so the host // may elide the durable run-activity reminder and drive the execution // locally (WorkflowsFastPath). Absent or unrecognised, the // durable reminder path is used. MetadataActivityLocalDrive = "localDrive" // MetadataActivityJanitorRedispatch marks a janitor re-dispatch, gated // on the execution-claim record so a body live on the previous owner is // deferred to (WorkflowsFastPath). Ignored by older hosts. MetadataActivityJanitorRedispatch = "janitorRedispatch" MetadataPurgeRetentionCall = "PurgeRetentionCall" MetadataPurgeForce = "PurgeForce" // Set on a WaitForRuntimeStatus call to request that a terminal workflow // also verify all of its child workflows, recursively, are terminal // before replying. Ignored by daprds that predate the flag. MetadataCheckSubtreeTerminal = "CheckSubtreeTerminal" // Set on a WaitForRuntimeStatus call to request a one-shot metadata fetch: // reply immediately with the current metadata, or ErrInstanceNotFound when // the instance does not exist, instead of parking the stream to wait for a // status change. Used for cross-app GetWorkflowMetadata. Daprds that // predate the flag ignore it, degrading to a wait rather than a failure. MetadataFetchOnly = "MetadataFetchOnly" // MetadataSenderInstanceID carries the instance ID of the child workflow // delivering its completion, so the parent can drop a completion for a // task whose child in the current generation is a different instance. MetadataSenderInstanceID = "SenderInstanceID" // MetadataParentExecutionID carries the execution ID of the workflow // generation that created the child or dispatched the activity, so a // completion delivered after the workflow continued as new is dropped: // task IDs restart with each generation. MetadataParentExecutionID = "ParentExecutionID" ActorTypePrefix = "dapr.internal." // ActivityReminderName is the per-activity-actor execution reminder name. // Shared so the orchestrator can reap an escalated reminder whose task // resolved while the escalation create was in flight. ActivityReminderName = "run-activity" )
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.WorkflowWorkItem) 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.