testing

Documentation

Index

• func AddActivityTaskCompletedEvent(builder execution.MutableState, scheduleID int64, startedID int64, ...) *workflow.HistoryEvent
• func AddActivityTaskFailedEvent(builder execution.MutableState, scheduleID int64, startedID int64, ...) *workflow.HistoryEvent
• func AddActivityTaskScheduledEvent(builder execution.MutableState, decisionCompletedID int64, activityID string, ...) (*workflow.HistoryEvent, *persistence.ActivityInfo)
• func AddActivityTaskScheduledEventWithRetry(builder execution.MutableState, decisionCompletedID int64, activityID string, ...) (*workflow.HistoryEvent, *persistence.ActivityInfo)
• func AddActivityTaskStartedEvent(builder execution.MutableState, scheduleID int64, identity string) *workflow.HistoryEvent
• func AddCancelRequestedEvent(builder execution.MutableState, initiatedID int64, domain string, ...) *workflow.HistoryEvent
• func AddChildWorkflowExecutionCompletedEvent(builder execution.MutableState, initiatedID int64, ...) *workflow.HistoryEvent
• func AddChildWorkflowExecutionStartedEvent(builder execution.MutableState, initiatedID int64, domain string, ...) *workflow.HistoryEvent
• func AddCompleteWorkflowEvent(builder execution.MutableState, decisionCompletedEventID int64, result []byte) *workflow.HistoryEvent
• func AddDecisionTaskCompletedEvent(builder execution.MutableState, scheduleID int64, startedID int64, ...) *workflow.HistoryEvent
• func AddDecisionTaskScheduledEvent(builder execution.MutableState) *execution.DecisionInfo
• func AddDecisionTaskStartedEvent(builder execution.MutableState, scheduleID int64, taskList string, ...) *workflow.HistoryEvent
• func AddDecisionTaskStartedEventWithRequestID(builder execution.MutableState, scheduleID int64, requestID string, ...) *workflow.HistoryEvent
• func AddFailWorkflowEvent(builder execution.MutableState, decisionCompletedEventID int64, reason string, ...) *workflow.HistoryEvent
• func AddRequestCancelInitiatedEvent(builder execution.MutableState, decisionCompletedEventID int64, ...) (*workflow.HistoryEvent, *persistence.RequestCancelInfo)
• func AddRequestSignalInitiatedEvent(builder execution.MutableState, decisionCompletedEventID int64, ...) (*workflow.HistoryEvent, *persistence.SignalInfo)
• func AddSignaledEvent(builder execution.MutableState, initiatedID int64, domain string, ...) *workflow.HistoryEvent
• func AddStartChildWorkflowExecutionInitiatedEvent(builder execution.MutableState, decisionCompletedID int64, ...) (*workflow.HistoryEvent, *persistence.ChildExecutionInfo)
• func AddTimerFiredEvent(mutableState execution.MutableState, timerID string) *workflow.HistoryEvent
• func AddTimerStartedEvent(builder execution.MutableState, decisionCompletedEventID int64, timerID string, ...) (*workflow.HistoryEvent, *persistence.TimerInfo)
• func AddWorkflowExecutionStartedEvent(builder execution.MutableState, workflowExecution workflow.WorkflowExecution, ...) *workflow.HistoryEvent
• func AddWorkflowExecutionStartedEventWithParent(builder execution.MutableState, workflowExecution workflow.WorkflowExecution, ...) *workflow.HistoryEvent

Functions

func AddActivityTaskCompletedEvent

func AddActivityTaskCompletedEvent(
	builder execution.MutableState,
	scheduleID int64,
	startedID int64,
	result []byte,
	identity string,
) *workflow.HistoryEvent

AddActivityTaskCompletedEvent adds ActivityTaskCompleted event

func AddActivityTaskFailedEvent

func AddActivityTaskFailedEvent(
	builder execution.MutableState,
	scheduleID int64,
	startedID int64,
	reason string,
	details []byte,
	identity string,
) *workflow.HistoryEvent

AddActivityTaskFailedEvent adds ActivityTaskFailed event

func AddActivityTaskScheduledEvent

func AddActivityTaskScheduledEvent(
	builder execution.MutableState,
	decisionCompletedID int64,
	activityID string,
	activityType string,
	taskList string,
	input []byte,
	scheduleToCloseTimeout int32,
	scheduleToStartTimeout int32,
	startToCloseTimeout int32,
	heartbeatTimeout int32,
) (*workflow.HistoryEvent,
	*persistence.ActivityInfo)

AddActivityTaskScheduledEvent adds ActivityTaskScheduled event

func AddActivityTaskScheduledEventWithRetry

func AddActivityTaskScheduledEventWithRetry(
	builder execution.MutableState,
	decisionCompletedID int64,
	activityID string,
	activityType string,
	taskList string,
	input []byte,
	scheduleToCloseTimeout int32,
	scheduleToStartTimeout int32,
	startToCloseTimeout int32,
	heartbeatTimeout int32,
	retryPolicy *workflow.RetryPolicy,
) (*workflow.HistoryEvent, *persistence.ActivityInfo)

AddActivityTaskScheduledEventWithRetry adds ActivityTaskScheduled event with retry policy

func AddActivityTaskStartedEvent

func AddActivityTaskStartedEvent(
	builder execution.MutableState,
	scheduleID int64,
	identity string,
) *workflow.HistoryEvent

AddActivityTaskStartedEvent adds ActivityTaskStarted event

func AddCancelRequestedEvent

func AddCancelRequestedEvent(
	builder execution.MutableState,
	initiatedID int64,
	domain string,
	workflowID string,
	runID string,
) *workflow.HistoryEvent

AddCancelRequestedEvent adds ExternalWorkflowExecutionCancelRequested event

func AddChildWorkflowExecutionCompletedEvent

func AddChildWorkflowExecutionCompletedEvent(
	builder execution.MutableState,
	initiatedID int64,
	childExecution *workflow.WorkflowExecution,
	attributes *workflow.WorkflowExecutionCompletedEventAttributes,
) *workflow.HistoryEvent

AddChildWorkflowExecutionCompletedEvent adds ChildWorkflowExecutionCompleted event

func AddChildWorkflowExecutionStartedEvent

func AddChildWorkflowExecutionStartedEvent(
	builder execution.MutableState,
	initiatedID int64,
	domain string,
	workflowID string,
	runID string,
	workflowType string,
) *workflow.HistoryEvent

AddChildWorkflowExecutionStartedEvent adds ChildWorkflowExecutionStarted event

func AddCompleteWorkflowEvent

func AddCompleteWorkflowEvent(
	builder execution.MutableState,
	decisionCompletedEventID int64,
	result []byte,
) *workflow.HistoryEvent

AddCompleteWorkflowEvent adds WorkflowExecutionCompleted event

func AddDecisionTaskCompletedEvent

func AddDecisionTaskCompletedEvent(
	builder execution.MutableState,
	scheduleID int64,
	startedID int64,
	context []byte,
	identity string,
) *workflow.HistoryEvent

AddDecisionTaskCompletedEvent adds DecisionTaskCompleted event

func AddDecisionTaskScheduledEvent

func AddDecisionTaskScheduledEvent(
	builder execution.MutableState,
) *execution.DecisionInfo

AddDecisionTaskScheduledEvent adds DecisionTaskScheduled event

func AddDecisionTaskStartedEvent

func AddDecisionTaskStartedEvent(
	builder execution.MutableState,
	scheduleID int64,
	taskList string,
	identity string,
) *workflow.HistoryEvent

AddDecisionTaskStartedEvent adds DecisionTaskStarted event

func AddDecisionTaskStartedEventWithRequestID

func AddDecisionTaskStartedEventWithRequestID(
	builder execution.MutableState,
	scheduleID int64,
	requestID string,
	taskList string,
	identity string,
) *workflow.HistoryEvent

AddDecisionTaskStartedEventWithRequestID adds DecisionTaskStarted event with requestID

func AddFailWorkflowEvent

func AddFailWorkflowEvent(
	builder execution.MutableState,
	decisionCompletedEventID int64,
	reason string,
	details []byte,
) *workflow.HistoryEvent

AddFailWorkflowEvent adds WorkflowExecutionFailed event

func AddRequestCancelInitiatedEvent

func AddRequestCancelInitiatedEvent(
	builder execution.MutableState,
	decisionCompletedEventID int64,
	cancelRequestID string,
	domain string,
	workflowID string,
	runID string,
) (*workflow.HistoryEvent, *persistence.RequestCancelInfo)

AddRequestCancelInitiatedEvent adds RequestCancelExternalWorkflowExecutionInitiated event

func AddRequestSignalInitiatedEvent

func AddRequestSignalInitiatedEvent(
	builder execution.MutableState,
	decisionCompletedEventID int64,
	signalRequestID string,
	domain string,
	workflowID string,
	runID string,
	signalName string,
	input []byte,
	control []byte,
) (*workflow.HistoryEvent, *persistence.SignalInfo)

AddRequestSignalInitiatedEvent adds SignalExternalWorkflowExecutionInitiated event

func AddSignaledEvent

func AddSignaledEvent(
	builder execution.MutableState,
	initiatedID int64,
	domain string,
	workflowID string,
	runID string,
	control []byte,
) *workflow.HistoryEvent

AddSignaledEvent adds ExternalWorkflowExecutionSignaled event

func AddStartChildWorkflowExecutionInitiatedEvent

func AddStartChildWorkflowExecutionInitiatedEvent(
	builder execution.MutableState,
	decisionCompletedID int64,
	createRequestID string,
	domain string,
	workflowID string,
	workflowType string,
	tasklist string,
	input []byte,
	executionStartToCloseTimeout int32,
	taskStartToCloseTimeout int32,
) (*workflow.HistoryEvent,
	*persistence.ChildExecutionInfo)

AddStartChildWorkflowExecutionInitiatedEvent adds ChildWorkflowExecutionInitiated event

func AddTimerFiredEvent

func AddTimerFiredEvent(
	mutableState execution.MutableState,
	timerID string,
) *workflow.HistoryEvent

AddTimerFiredEvent adds TimerFired event

func AddTimerStartedEvent

func AddTimerStartedEvent(
	builder execution.MutableState,
	decisionCompletedEventID int64,
	timerID string,
	timeOut int64,
) (*workflow.HistoryEvent, *persistence.TimerInfo)

AddTimerStartedEvent adds TimerStarted event

func AddWorkflowExecutionStartedEvent

func AddWorkflowExecutionStartedEvent(
	builder execution.MutableState,
	workflowExecution workflow.WorkflowExecution,
	workflowType string,
	taskList string,
	input []byte,
	executionStartToCloseTimeout int32,
	taskStartToCloseTimeout int32,
	identity string,
) *workflow.HistoryEvent

AddWorkflowExecutionStartedEvent adds WorkflowExecutionStarted event

func AddWorkflowExecutionStartedEventWithParent

func AddWorkflowExecutionStartedEventWithParent(
	builder execution.MutableState,
	workflowExecution workflow.WorkflowExecution,
	workflowType string,
	taskList string,
	input []byte,
	executionStartToCloseTimeout,
	taskStartToCloseTimeout int32,
	parentInfo *history.ParentExecutionInfo,
	identity string,
) *workflow.HistoryEvent

AddWorkflowExecutionStartedEventWithParent adds WorkflowExecutionStarted event with parent workflow info