helpers

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

func CancelSpan(span trace.Span)

func ChangeSpanID(span trace.Span, newSpanID trace.SpanID)

func ContextFromTraceContext(ctx context.Context, tc *protos.TraceContext) (context.Context, error)

func FromRuntimeStatusString(status string) protos.OrchestrationStatus

func GetDefaultWorkerName() string

func GetTaskFunctionName(f any) string

func GetTaskId(e *protos.HistoryEvent) int32

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

func NewCompleteOrchestrationAction(
	taskID int32,
	status protos.OrchestrationStatus,
	rawResult *wrapperspb.StringValue,
	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(
	name string,
	instanceId string,
	input *wrapperspb.StringValue,
	parent *protos.ParentInstanceInfo,
	parentTraceContext *protos.TraceContext,
) *protos.HistoryEvent

func NewExecutionTerminatedEvent(rawReason *wrapperspb.StringValue, recurse bool) *protos.HistoryEvent

func NewOrchestratorStartedEvent() *protos.HistoryEvent

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

func NewResumeOrchestrationEvent(reason string) *protos.HistoryEvent

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,
	parentTraceContext *protos.TraceContext,
) *protos.HistoryEvent

func NewSuspendOrchestrationEvent(reason string) *protos.HistoryEvent

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

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

func NewTaskFailureDetails(err error) *protos.TaskFailureDetails

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

func NewTerminateOrchestrationAction(taskID int32, iid string, recurse bool, rawReason *wrapperspb.StringValue) *protos.OrchestratorAction

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

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

func NoopSpan() trace.Span

func SpanContextFromTraceContext(tc *protos.TraceContext) (trace.SpanContext, error)

func StartAndEndNewTimerSpan(ctx context.Context, tf *protos.TimerFiredEvent, createdTime time.Time, instanceID string) error

func StartNewActivitySpan(
	ctx context.Context, name string, version string, instanceID string, taskID int32,
) (context.Context, trace.Span)

func StartNewCreateOrchestrationSpan(
	ctx context.Context, name string, version string, instanceID string,
) (context.Context, trace.Span)

func StartNewRunOrchestrationSpan(
	ctx context.Context, es *protos.ExecutionStartedEvent, startedTime time.Time,
) (context.Context, trace.Span)

func ToRuntimeStatusString(status protos.OrchestrationStatus) string

func TraceContextFromSpan(span trace.Span) *protos.TraceContext

func UnsafeSetSpanContext(span trace.Span, spanContext trace.SpanContext) bool