Versions in this module Expand all Collapse all v0 v0.1.0 Sep 1, 2026 Changes in this version + const ActivityEdgeGroupProcess + const ActivityExecutorProcess + const ActivityMessageSend + const ActivityWorkflowBuild + const ActivityWorkflowInvoke + const ActivityWorkflowSession + const EventBuildCompleted + const EventBuildError + const EventBuildStarted + const EventBuildValidationCompleted + const EventSessionCompleted + const EventSessionError + const EventSessionStarted + const EventWorkflowCompleted + const EventWorkflowError + const EventWorkflowStarted + const TagBuildErrorMessage + const TagBuildErrorType + const TagEdgeGroupDelivered + const TagEdgeGroupDeliveryStatus + const TagEdgeGroupType + const TagErrorMessage + const TagErrorType + const TagExecutorID + const TagExecutorInput + const TagExecutorOutput + const TagExecutorType + const TagMessageContent + const TagMessageSourceID + const TagMessageTargetID + const TagMessageType + const TagSessionID + const TagWorkflowDefinition + const TagWorkflowDescription + const TagWorkflowID + const TagWorkflowName + func BuildErrorAttributes(err error) []workflowobservability.Attribute + func ContextWithTelemetry(ctx context.Context, telemetry *Context) context.Context + func ErrorAttributes(err error) []workflowobservability.Attribute + func SerializedAttribute(key string, value any) workflowobservability.Attribute + func SetBuildWorkflowAttributes(span *Activity, metadata WorkflowMetadata, definition any) + type Activity struct + func (s *Activity) AddErrorEvent(name string, err error) + func (s *Activity) AddEvent(name string, attrs ...workflowobservability.Attribute) + func (s *Activity) CaptureError(err error) + func (s *Activity) End() + func (s *Activity) SetAttributes(attrs ...workflowobservability.Attribute) + func (s *Activity) SetDeliveryStatus(status DeliveryStatus) + type Context struct + func Disabled() *Context + func FromContext(ctx context.Context) *Context + func New(options Options) *Context + func (c *Context) ExtractTraceContext(ctx context.Context) map[string]string + func (c *Context) IsEnabled() bool + func (c *Context) SetExecutorOutput(span *Activity, output any) + func (c *Context) StartEdgeGroupProcess(ctx context.Context, metadata EdgeGroupMetadata) (context.Context, *Activity) + func (c *Context) StartExecutorProcess(ctx context.Context, executorID, executorType, messageType string, message any, ...) (context.Context, *Activity) + func (c *Context) StartMessageSend(ctx context.Context, sourceID, targetID string, message any) (context.Context, *Activity) + func (c *Context) StartWorkflowBuild(ctx context.Context) (context.Context, *Activity) + func (c *Context) StartWorkflowRun(ctx context.Context, metadata WorkflowMetadata) (context.Context, *Activity) + func (c *Context) StartWorkflowSession(ctx context.Context, metadata WorkflowMetadata) (context.Context, *Activity) + type DeliveryStatus string + const DeliveryStatusBuffered + const DeliveryStatusDelivered + const DeliveryStatusDroppedConditionFalse + const DeliveryStatusDroppedTargetMismatch + const DeliveryStatusDroppedTypeMismatch + const DeliveryStatusException + type EdgeGroupMetadata struct + SourceID string + TargetID string + Type string + type Options struct + DisableEdgeGroupProcess bool + DisableExecutorProcess bool + DisableMessageSend bool + DisableWorkflowBuild bool + DisableWorkflowRun bool + EnableSensitiveData bool + Tracer workflowobservability.Tracer + type WorkflowMetadata struct + Description string + ID string + Name string + SessionID string
Go to main page