Help us shape the future of Go! Take the 2026 Go Developer Survey

todo

package
v1.18.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2026 License: Apache-2.0 Imports: 3 Imported by: 0

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"
	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"

	// 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 parent execution ID the child was
	// created under, so a completion re-sent after the parent continued as
	// new is dropped even when the child instance ID is reused.
	MetadataParentExecutionID = "ParentExecutionID"

	ActorTypePrefix = "dapr.internal."
)

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL