Documentation
¶
Index ¶
- type CancelableCommand
- type Command
- type CommandResult
- type CommandState
- type 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
- 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
- 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
- type ScheduleTimerCommand
- type 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
- 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())
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CancelableCommand ¶
type CancelableCommand interface {
Command
// Cancel cancels the command.
Cancel()
// HandleCancel handles a cancel event during replay
HandleCancel()
}
type Command ¶
type Command interface {
ID() int64
Type() string
// State returns the current state of the command.
State() CommandState
// Execute processes the command in its current state and moves it to the next state.
Execute(clock.Clock) *CommandResult
// Commit marks the command as committed without executing it.
Commit()
// Done marks the command as done. This transitions the state to done and indicates that the result
// of this command has been applied.
Done()
WhenDone(fn func())
}
type CommandResult ¶
type CommandResult struct {
State core.WorkflowInstanceState
Events []*history.Event
ActivityEvents []*history.Event
TimerEvents []*history.Event
WorkflowEvents []*history.WorkflowEvent
}
type CommandState ¶
type CommandState int
const ( CommandState_Pending CommandState = iota CommandState_Committed CommandState_CancelPending CommandState_Canceled CommandState_Done )
func (CommandState) String ¶
func (cs CommandState) String() string
type CompleteWorkflowCommand ¶
type CompleteWorkflowCommand struct {
Instance *core.WorkflowInstance
Result payload.Payload
Error *workflowerrors.Error
// contains filtered or unexported fields
}
func NewCompleteWorkflowCommand ¶
func NewCompleteWorkflowCommand(id int64, instance *core.WorkflowInstance, result payload.Payload, err *workflowerrors.Error) *CompleteWorkflowCommand
func (*CompleteWorkflowCommand) Commit ¶
func (c *CompleteWorkflowCommand) Commit()
func (*CompleteWorkflowCommand) Execute ¶
func (c *CompleteWorkflowCommand) Execute(clock clock.Clock) *CommandResult
func (*CompleteWorkflowCommand) State ¶
func (c *CompleteWorkflowCommand) State() CommandState
type ContinueAsNewCommand ¶
type ContinueAsNewCommand struct {
Instance *core.WorkflowInstance
Name string
Metadata *metadata.WorkflowMetadata
Inputs []payload.Payload
Result payload.Payload
ContinuedExecutionID string
// contains filtered or unexported fields
}
func NewContinueAsNewCommand ¶
func NewContinueAsNewCommand(id int64, instance *core.WorkflowInstance, result payload.Payload, name string, metadata *metadata.WorkflowMetadata, inputs []payload.Payload) *ContinueAsNewCommand
func (*ContinueAsNewCommand) Execute ¶
func (c *ContinueAsNewCommand) Execute(clock clock.Clock) *CommandResult
func (*ContinueAsNewCommand) State ¶
func (c *ContinueAsNewCommand) State() CommandState
type ScheduleActivityCommand ¶
type ScheduleActivityCommand struct {
Name string
Inputs []payload.Payload
Attempt int
Metadata *metadata.WorkflowMetadata
Queue core.Queue
// contains filtered or unexported fields
}
func NewScheduleActivityCommand ¶
func NewScheduleActivityCommand(id int64, name string, inputs []payload.Payload, attempt int, metadata *metadata.WorkflowMetadata, queue core.Queue) *ScheduleActivityCommand
func (*ScheduleActivityCommand) Execute ¶
func (c *ScheduleActivityCommand) Execute(clock clock.Clock) *CommandResult
func (*ScheduleActivityCommand) State ¶
func (c *ScheduleActivityCommand) State() CommandState
type ScheduleSubWorkflowCommand ¶
type ScheduleSubWorkflowCommand struct {
Queue core.Queue
Instance *core.WorkflowInstance
Metadata *metadata.WorkflowMetadata
WorkflowSpanID [8]byte
Name string
Inputs []payload.Payload
// contains filtered or unexported fields
}
func NewScheduleSubWorkflowCommand ¶
func NewScheduleSubWorkflowCommand( id int64, parentInstance *core.WorkflowInstance, subWorkflowQueue core.Queue, subWorkflowInstanceID, name string, inputs []payload.Payload, metadata *metadata.WorkflowMetadata, workflowSpanID [8]byte, ) *ScheduleSubWorkflowCommand
func (*ScheduleSubWorkflowCommand) Execute ¶
func (c *ScheduleSubWorkflowCommand) Execute(clock clock.Clock) *CommandResult
func (*ScheduleSubWorkflowCommand) HandleCancel ¶
func (c *ScheduleSubWorkflowCommand) HandleCancel()
type ScheduleTimerCommand ¶
type ScheduleTimerCommand struct {
// contains filtered or unexported fields
}
func NewScheduleTimerCommand ¶
func (*ScheduleTimerCommand) Execute ¶
func (c *ScheduleTimerCommand) Execute(clock clock.Clock) *CommandResult
func (*ScheduleTimerCommand) HandleCancel ¶
func (c *ScheduleTimerCommand) HandleCancel()
type SideEffectCommand ¶
type SideEffectCommand struct {
// contains filtered or unexported fields
}
func NewSideEffectCommand ¶
func NewSideEffectCommand(id int64) *SideEffectCommand
func (*SideEffectCommand) Commit ¶
func (c *SideEffectCommand) Commit()
func (*SideEffectCommand) Done ¶
func (c *SideEffectCommand) Done()
func (*SideEffectCommand) Execute ¶
func (c *SideEffectCommand) Execute(clock clock.Clock) *CommandResult
func (*SideEffectCommand) SetResult ¶
func (c *SideEffectCommand) SetResult(result payload.Payload)
func (*SideEffectCommand) State ¶
func (c *SideEffectCommand) State() CommandState
type StartTraceCommand ¶
type StartTraceCommand struct {
// contains filtered or unexported fields
}
func NewStartTraceCommand ¶
func NewStartTraceCommand(id int64) *StartTraceCommand
func (*StartTraceCommand) Commit ¶
func (c *StartTraceCommand) Commit()
func (*StartTraceCommand) Done ¶
func (c *StartTraceCommand) Done()
func (*StartTraceCommand) Execute ¶
func (c *StartTraceCommand) Execute(clock clock.Clock) *CommandResult
func (*StartTraceCommand) SetSpanID ¶
func (c *StartTraceCommand) SetSpanID(spanID payload.Payload)
func (*StartTraceCommand) State ¶
func (c *StartTraceCommand) State() CommandState
Source Files
Click to show internal directories.
Click to hide internal directories.