helpers

func ActionListSummary(actions []*protos.OrchestratorAction) string

func GetTaskId(e *protos.HistoryEvent) int32

func HistoryListSummary(list []*protos.HistoryEvent) string

func NewCompleteOrchestrationAction(
	taskID int32,
	status protos.OrchestrationStatus,
	result string,
	carryoverEvents []*protos.HistoryEvent,
	failureDetails *protos.TaskFailureDetails) *protos.OrchestratorAction

func NewCreateSubOrchestrationAction(
	taskID int32,
	name string,
	iid string,
	input *wrapperspb.StringValue) *protos.OrchestratorAction

func NewCreateTimerAction(taskID int32, fireAt time.Time) *protos.OrchestratorAction

func NewEventRaisedEvent(name string, rawInput *wrapperspb.StringValue) *protos.HistoryEvent

func NewExecutionCompletedEvent(eventID int32, status protos.OrchestrationStatus, result *wrapperspb.StringValue, failureDetails *protos.TaskFailureDetails) *protos.HistoryEvent

func NewExecutionStartedEvent(
	eventID int32,
	name string,
	instanceId string,
	input *wrapperspb.StringValue,
	parent *protos.ParentInstanceInfo) *protos.HistoryEvent

func NewExecutionTerminatedEvent(rawReason *wrapperspb.StringValue) *protos.HistoryEvent

func NewOrchestratorStartedEvent() *protos.HistoryEvent

func NewParentInfo(taskID int32, name string, iid string) *protos.ParentInstanceInfo

func NewScheduleTaskAction(taskID int32, name string, input *wrapperspb.StringValue) *protos.OrchestratorAction

func NewSendEventAction(iid string, name string, data *wrapperspb.StringValue) *protos.OrchestratorAction

func NewSendEventEvent(eventID int32, instanceID string, name string, rawInput *wrapperspb.StringValue) *protos.HistoryEvent

func NewSubOrchestrationCreatedEvent(eventID int32, name string, version *wrapperspb.StringValue, rawInput *wrapperspb.StringValue, instanceID string) *protos.HistoryEvent

func NewTaskCompletedEvent(taskID int32, result *wrapperspb.StringValue) *protos.HistoryEvent

func NewTaskFailedEvent(taskID int32, failureDetails *protos.TaskFailureDetails) *protos.HistoryEvent

func NewTaskScheduledEvent(taskID int32, name string, version *wrapperspb.StringValue, rawInput *wrapperspb.StringValue) *protos.HistoryEvent

func NewTimerCreatedEvent(eventID int32, fireAt *timestamppb.Timestamp) *protos.HistoryEvent

func NewTimerFiredEvent(timerID int32, fireAt *timestamppb.Timestamp) *protos.HistoryEvent