command

type CancelableCommand interface {
	Command

	// Cancel cancels the command.
	Cancel()

	// HandleCancel handles a cancel event during replay
	HandleCancel()
}

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

type CommandResult struct {
	Completed      bool
	Events         []history.Event
	ActivityEvents []history.Event
	TimerEvents    []history.Event
	WorkflowEvents []history.WorkflowEvent
}

type CommandState int

type CompleteWorkflowCommand struct {
	Instance *core.WorkflowInstance
	Result   payload.Payload
	Error    string
	// contains filtered or unexported fields
}

type ScheduleActivityCommand struct {
	Name   string
	Inputs []payload.Payload
	// contains filtered or unexported fields
}

type ScheduleSubWorkflowCommand struct {
	Instance *core.WorkflowInstance
	Metadata *core.WorkflowMetadata

	Name   string
	Inputs []payload.Payload
	// contains filtered or unexported fields
}

type ScheduleTimerCommand struct {
	// contains filtered or unexported fields
}

type SideEffectCommand struct {
	// contains filtered or unexported fields
}

type SignalWorkflowCommand struct {
	Instance *core.WorkflowInstance

	Name string
	Arg  payload.Payload
	// contains filtered or unexported fields
}