task

Jul 13, 2023

Changes in this version

+ func WithActivityInput(input any) callActivityOption

+ func WithRawActivityInput(input string) callActivityOption

+ func WithRawSubOrchestratorInput(input string) subOrchestratorOption

+ func WithSubOrchestrationInstanceID(instanceID string) subOrchestratorOption

+ func WithSubOrchestratorInput(input any) subOrchestratorOption

type OrchestrationContext

+ func (ctx *OrchestrationContext) CallSubOrchestrator(orchestrator interface{}, opts ...subOrchestratorOption) Task

May 1, 2023

Changes in this version

+ type ContinueAsNewOption func(*OrchestrationContext)

+ func WithKeepUnprocessedEvents() ContinueAsNewOption

Jan 20, 2023

Changes in this version

+ var ErrTaskBlocked = errors.New("the current task is blocked")

+ var ErrTaskCanceled = errors.New("the task was canceled")

+ func NewTaskExecutor(registry *TaskRegistry) backend.Executor

+ type Activity func(ctx ActivityContext) (any, error)

+ type ActivityContext interface

+ Context func() context.Context

+ GetInput func(resultPtr any) error

+ type OrchestrationContext struct

+ CurrentTimeUtc time.Time

+ ID api.InstanceID

+ IsReplaying bool

+ Name string

+ func NewOrchestrationContext(registry *TaskRegistry, id api.InstanceID, oldEvents []*protos.HistoryEvent, ...) *OrchestrationContext

+ func (ctx *OrchestrationContext) CallActivity(activity interface{}, input any) Task

+ func (ctx *OrchestrationContext) ContinueAsNew(newInput any)

+ func (ctx *OrchestrationContext) CreateTimer(delay time.Duration) Task

+ func (ctx *OrchestrationContext) WaitForSingleEvent(eventName string, timeout time.Duration) Task

+ func (octx *OrchestrationContext) GetInput(v any) error

+ type Orchestrator func(ctx *OrchestrationContext) (any, error)

+ type Task interface

+ Await func(v any) error

+ type TaskRegistry struct

+ func NewTaskRegistry() *TaskRegistry

+ func (r *TaskRegistry) AddActivity(a Activity) error

+ func (r *TaskRegistry) AddActivityN(name string, a Activity) error

+ func (r *TaskRegistry) AddOrchestrator(o Orchestrator) error

+ func (r *TaskRegistry) AddOrchestratorN(name string, o Orchestrator) error