Documentation
¶
Index ¶
- 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 NoopSpan() trace.Span
- func SpanContextFromTraceContext(tc *protos.TraceContext) (trace.SpanContext, error)
- func StartAndEndNewTimerSpan(ctx context.Context, tf *protos.TimerFiredEvent, createdTime time.Time, ...) error
- func StartNewActivitySpan(ctx context.Context, name string, version string, instanceID string, ...) (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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ActionListSummary ¶
func ActionListSummary(actions []*protos.OrchestratorAction) string
func CancelSpan ¶
func ContextFromTraceContext ¶
func FromRuntimeStatusString ¶
func FromRuntimeStatusString(status string) protos.OrchestrationStatus
func GetDefaultWorkerName ¶
func GetDefaultWorkerName() string
func GetTaskFunctionName ¶
func GetTaskId ¶
func GetTaskId(e *protos.HistoryEvent) int32
func HistoryListSummary ¶
func HistoryListSummary(list []*protos.HistoryEvent) string
func SpanContextFromTraceContext ¶
func SpanContextFromTraceContext(tc *protos.TraceContext) (trace.SpanContext, error)
func StartAndEndNewTimerSpan ¶
func StartNewActivitySpan ¶
func ToRuntimeStatusString ¶
func ToRuntimeStatusString(status protos.OrchestrationStatus) string
func TraceContextFromSpan ¶
func TraceContextFromSpan(span trace.Span) *protos.TraceContext
func UnsafeSetSpanContext ¶
func UnsafeSetSpanContext(span trace.Span, spanContext trace.SpanContext) bool
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.