command

Oct 27, 2024

Changes in this version

type ContinueAsNewCommand

+ ContinuedExecutionID string

type ScheduleActivityCommand

+ Attempt int

+ Queue core.Queue

type ScheduleSubWorkflowCommand

+ Queue core.Queue

+ WorkflowSpanID [8]byte

+ 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())

Jun 3, 2023

Changes in this version

type CommandResult

+ State core.WorkflowInstanceState

+ type ContinueAsNewCommand struct

+ Inputs []payload.Payload

+ Instance *core.WorkflowInstance

+ Metadata *core.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())

May 30, 2023

Changes in this version

type ScheduleActivityCommand

+ Metadata *core.WorkflowMetadata

Apr 4, 2023

Changes in this version

type Command

+ WhenDone func(fn func())

type CompleteWorkflowCommand

+ func (c *CompleteWorkflowCommand) WhenDone(fn func())

type ScheduleActivityCommand

+ func (c *ScheduleActivityCommand) WhenDone(fn func())

type SideEffectCommand

+ func (c *SideEffectCommand) WhenDone(fn func())

Aug 15, 2022

Changes in this version

+ type CancelableCommand interface

+ Cancel func()

+ HandleCancel func()

type Command

+ Execute func(clock.Clock) *CommandResult

type CommandState

+ const CommandState_CancelPending

+ const CommandState_Canceled

+ func (cs CommandState) String() string

type CompleteWorkflowCommand

+ func (c *CompleteWorkflowCommand) Execute(clock clock.Clock) *CommandResult

type ScheduleActivityCommand

+ func (c *ScheduleActivityCommand) Execute(clock clock.Clock) *CommandResult

type ScheduleSubWorkflowCommand

+ func (c *ScheduleSubWorkflowCommand) Cancel()

+ func (c *ScheduleSubWorkflowCommand) Execute(clock clock.Clock) *CommandResult

+ func (c *ScheduleSubWorkflowCommand) HandleCancel()

type ScheduleTimerCommand

+ func (c *ScheduleTimerCommand) Cancel()

+ func (c *ScheduleTimerCommand) Execute(clock clock.Clock) *CommandResult

+ func (c *ScheduleTimerCommand) HandleCancel()

type SideEffectCommand

+ func (c *SideEffectCommand) Execute(clock clock.Clock) *CommandResult

type SignalWorkflowCommand

+ func (c *SignalWorkflowCommand) Execute(clock clock.Clock) *CommandResult

Aug 9, 2022

Changes in this version

type SideEffectCommand

+ func (c *SideEffectCommand) SetResult(result payload.Payload)

+ type SignalWorkflowCommand struct

+ Arg payload.Payload

+ Instance *core.WorkflowInstance

+ Name string

+ func NewSignalWorkflowCommand(id int64, workflowInstanceID, name string, arg payload.Payload) *SignalWorkflowCommand

+ func (*SignalWorkflowCommand) Type() string

+ func (c *SignalWorkflowCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *SignalWorkflowCommand) Committed() bool

+ func (c *SignalWorkflowCommand) Done()

+ func (c *SignalWorkflowCommand) ID() int64

+ func (c *SignalWorkflowCommand) State() CommandState

Jul 27, 2022

Changes in this version

type CancelSubWorkflowCommand

+ func (c *CancelSubWorkflowCommand) Committed() bool

+ type CancelTimerCommand struct

+ TimerScheduleEventID int64

+ func (*CancelTimerCommand) Type() string

+ func (c *CancelTimerCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *CancelTimerCommand) Committed() bool

+ func (c *CancelTimerCommand) Done()

+ func (c *CancelTimerCommand) ID() int64

+ func (c *CancelTimerCommand) State() CommandState

type Command

+ Committed func() bool

type CompleteWorkflowCommand

+ func (c *CompleteWorkflowCommand) Committed() bool

type ScheduleActivityCommand

+ func (c *ScheduleActivityCommand) Committed() bool

type ScheduleSubWorkflowCommand

+ func (c *ScheduleSubWorkflowCommand) Committed() bool

type ScheduleTimerCommand

+ func (c *ScheduleTimerCommand) Committed() bool

+ type SideEffectCommand struct

+ func (c *SideEffectCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *SideEffectCommand) Committed() bool

+ func (c *SideEffectCommand) Done()

+ func (c *SideEffectCommand) ID() int64

+ func (c *SideEffectCommand) State() CommandState

+ func (c *SideEffectCommand) Type() string

Jun 21, 2022

Changes in this version

+ type CancelSubWorkflowCommand struct

+ SubWorkflowInstance *core.WorkflowInstance

+ func (*CancelSubWorkflowCommand) Type() string

+ func (c *CancelSubWorkflowCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *CancelSubWorkflowCommand) Done()

+ func (c *CancelSubWorkflowCommand) ID() int64

+ func (c *CancelSubWorkflowCommand) State() CommandState

type Command

+ func NewScheduleActivityCommand(id int64, name string, inputs []payload.Payload) Command

+ Commit func(clock clock.Clock) *CommandResult

+ Done func()

+ type CommandResult struct

+ ActivityEvents []history.Event

+ Completed bool

+ Events []history.Event

+ TimerEvents []history.Event

+ WorkflowEvents []history.WorkflowEvent

+ type CompleteWorkflowCommand struct

+ Error string

+ Instance *core.WorkflowInstance

+ Result payload.Payload

+ func (*CompleteWorkflowCommand) Type() string

+ func (c *CompleteWorkflowCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *CompleteWorkflowCommand) Done()

+ func (c *CompleteWorkflowCommand) ID() int64

+ func (c *CompleteWorkflowCommand) State() CommandState

+ type ScheduleActivityCommand struct

+ Inputs []payload.Payload

+ Name string

+ func (*ScheduleActivityCommand) Type() string

+ func (c *ScheduleActivityCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *ScheduleActivityCommand) Done()

+ func (c *ScheduleActivityCommand) ID() int64

+ func (c *ScheduleActivityCommand) State() CommandState

+ type ScheduleSubWorkflowCommand struct

+ Inputs []payload.Payload

+ Instance *core.WorkflowInstance

+ Metadata *core.WorkflowMetadata

+ Name string

+ func (*ScheduleSubWorkflowCommand) Type() string

+ func (c *ScheduleSubWorkflowCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *ScheduleSubWorkflowCommand) Done()

+ func (c *ScheduleSubWorkflowCommand) ID() int64

+ func (c *ScheduleSubWorkflowCommand) State() CommandState

+ type ScheduleTimerCommand struct

+ func (c *ScheduleTimerCommand) Commit(clock clock.Clock) *CommandResult

+ func (c *ScheduleTimerCommand) Done()

+ func (c *ScheduleTimerCommand) ID() int64

+ func (c *ScheduleTimerCommand) State() CommandState

+ func (c *ScheduleTimerCommand) Type() string

May 6, 2022

Changes in this version

type CommandType

+ const CommandType_ScheduleActivity

+ func (ct CommandType) String() string

Apr 26, 2022

Changes in this version

+ type CancelSubWorkflowCommandAttr struct

+ SubWorkflowInstance *core.WorkflowInstance

type CancelTimerCommandAttr

+ TimerScheduleEventID int64

type Command

+ func NewCancelSubWorkflowCommand(id int64, subWorkflowInstance *core.WorkflowInstance) Command

type CommandType

+ const CommandType_CancelSubWorkflow

type ScheduleSubWorkflowCommandAttr

+ Instance *core.WorkflowInstance

Mar 9, 2022

Changes in this version

+ type CancelTimerCommandAttr struct

+ TimerID int

+ type Command struct

+ Attr interface{}

+ ID int

+ State CommandState

+ Type CommandType

+ func NewCancelTimerCommand(id, timerID int) Command

+ func NewCompleteWorkflowCommand(id int, result payload.Payload, err error) Command

+ func NewScheduleActivityTaskCommand(id int, name string, inputs []payload.Payload) Command

+ func NewScheduleSubWorkflowCommand(id int, instanceID, name string, inputs []payload.Payload) Command

+ func NewScheduleTimerCommand(id int, at time.Time) Command

+ func NewSideEffectCommand(id int, result payload.Payload) Command

+ type CommandState int

+ const CommandState_Committed

+ const CommandState_Done

+ const CommandState_Pending

+ type CommandType int

+ const CommandType_CancelTimer

+ const CommandType_CompleteWorkflow

+ const CommandType_ScheduleActivityTask

+ const CommandType_ScheduleSubWorkflow

+ const CommandType_ScheduleTimer

+ const CommandType_SideEffect

+ type CompleteWorkflowCommandAttr struct

+ Error string

+ Result payload.Payload

+ type ScheduleActivityTaskCommandAttr struct

+ Inputs []payload.Payload

+ Name string

+ type ScheduleSubWorkflowCommandAttr struct

+ Inputs []payload.Payload

+ InstanceID string

+ Name string

+ type ScheduleTimerCommandAttr struct

+ At time.Time

+ type SideEffectCommandAttr struct

+ Result payload.Payload