Versions in this module Expand all Collapse all v0 v0.1.0 Apr 8, 2026 Changes in this version + type CancelableCommand interface + Cancel func() + HandleCancel func() + type Command interface + Commit func() + Done func() + Execute func(clock.Clock) *CommandResult + ID func() int64 + State func() CommandState + Type func() string + WhenDone func(fn func()) + type CommandResult struct + ActivityEvents []*history.Event + Events []*history.Event + State core.WorkflowInstanceState + TimerEvents []*history.Event + WorkflowEvents []*history.WorkflowEvent + type CommandState int + const CommandState_CancelPending + const CommandState_Canceled + const CommandState_Committed + const CommandState_Done + const CommandState_Pending + func (cs CommandState) String() string + type CompleteWorkflowCommand struct + Error *workflowerrors.Error + Instance *core.WorkflowInstance + Result payload.Payload + func NewCompleteWorkflowCommand(id int64, instance *core.WorkflowInstance, result payload.Payload, ...) *CompleteWorkflowCommand + func (c *CompleteWorkflowCommand) Commit() + func (c *CompleteWorkflowCommand) Done() + func (c *CompleteWorkflowCommand) Execute(clock clock.Clock) *CommandResult + func (c *CompleteWorkflowCommand) ID() int64 + func (c *CompleteWorkflowCommand) State() CommandState + func (c *CompleteWorkflowCommand) Type() string + func (c *CompleteWorkflowCommand) WhenDone(fn func()) + type ContinueAsNewCommand struct + ContinuedExecutionID string + Inputs []payload.Payload + Instance *core.WorkflowInstance + Metadata *metadata.WorkflowMetadata + Name string + Result payload.Payload + func NewContinueAsNewCommand(id int64, instance *core.WorkflowInstance, result payload.Payload, name string, ...) *ContinueAsNewCommand + func (c *ContinueAsNewCommand) Commit() + func (c *ContinueAsNewCommand) Done() + func (c *ContinueAsNewCommand) Execute(clock clock.Clock) *CommandResult + func (c *ContinueAsNewCommand) ID() int64 + func (c *ContinueAsNewCommand) State() CommandState + func (c *ContinueAsNewCommand) Type() string + func (c *ContinueAsNewCommand) WhenDone(fn func()) + type ScheduleActivityCommand struct + Attempt int + Inputs []payload.Payload + Metadata *metadata.WorkflowMetadata + Name string + Queue core.Queue + func NewScheduleActivityCommand(id int64, name string, inputs []payload.Payload, attempt int, ...) *ScheduleActivityCommand + func (c *ScheduleActivityCommand) Commit() + func (c *ScheduleActivityCommand) Done() + func (c *ScheduleActivityCommand) Execute(clock clock.Clock) *CommandResult + func (c *ScheduleActivityCommand) ID() int64 + func (c *ScheduleActivityCommand) State() CommandState + func (c *ScheduleActivityCommand) Type() string + func (c *ScheduleActivityCommand) WhenDone(fn func()) + type ScheduleSubWorkflowCommand struct + Inputs []payload.Payload + Instance *core.WorkflowInstance + Metadata *metadata.WorkflowMetadata + Name string + Queue core.Queue + WorkflowSpanID [8]byte + func NewScheduleSubWorkflowCommand(id int64, parentInstance *core.WorkflowInstance, subWorkflowQueue core.Queue, ...) *ScheduleSubWorkflowCommand + func (c *ScheduleSubWorkflowCommand) Cancel() + func (c *ScheduleSubWorkflowCommand) Done() + func (c *ScheduleSubWorkflowCommand) Execute(clock clock.Clock) *CommandResult + func (c *ScheduleSubWorkflowCommand) HandleCancel() + type ScheduleTimerCommand struct + func NewScheduleTimerCommand(id int64, at time.Time, name string, traceContext tracing.Context) *ScheduleTimerCommand + func (c *ScheduleTimerCommand) Cancel() + func (c *ScheduleTimerCommand) Done() + func (c *ScheduleTimerCommand) Execute(clock clock.Clock) *CommandResult + func (c *ScheduleTimerCommand) HandleCancel() + type SideEffectCommand struct + func NewSideEffectCommand(id int64) *SideEffectCommand + func (c *SideEffectCommand) Commit() + func (c *SideEffectCommand) Done() + func (c *SideEffectCommand) Execute(clock clock.Clock) *CommandResult + func (c *SideEffectCommand) ID() int64 + func (c *SideEffectCommand) SetResult(result payload.Payload) + func (c *SideEffectCommand) State() CommandState + func (c *SideEffectCommand) Type() string + func (c *SideEffectCommand) WhenDone(fn func()) + type StartTraceCommand struct + func NewStartTraceCommand(id int64) *StartTraceCommand + func (c *StartTraceCommand) Commit() + func (c *StartTraceCommand) Done() + func (c *StartTraceCommand) Execute(clock clock.Clock) *CommandResult + func (c *StartTraceCommand) ID() int64 + func (c *StartTraceCommand) SetSpanID(spanID payload.Payload) + func (c *StartTraceCommand) State() CommandState + func (c *StartTraceCommand) Type() string + func (c *StartTraceCommand) WhenDone(fn func())
Go to main page