tracing

Documentation

Index

• Variables
• func AnnotateSpanWithChainInfo(ctx context.Context, span trace.Span, chain *tasks.Chain)
• func AnnotateSpanWithChordInfo(ctx context.Context, span trace.Span, chord *tasks.Chord, sendConcurrency int)
• func AnnotateSpanWithGroupInfo(ctx context.Context, span trace.Span, group *tasks.Group, sendConcurrency int)
• func AnnotateSpanWithSignatureInfo(span trace.Span, signature *tasks.Signature)
• func HeadersWithSpan(ctx context.Context, headers http.Header) http.Header
• func StartSpanFromHeaders(ctx context.Context, headers http.Header, operationName string) (_spanCtx context.Context, _span trace.Span)

Variables

var (
	MachineryTag       = attribute.String("component", "machinery")
	WorkflowGroupTag   = attribute.String("machinery.workflow", "group")
	WorkflowChordTag   = attribute.String("machinery.workflow", "chord")
	WorkflowChainTag   = attribute.String("machinery.workflow", "chain")
	MachineryTraceName = "machinery"
)

opentelemetry tags

Functions

func AnnotateSpanWithChainInfo

func AnnotateSpanWithChainInfo(ctx context.Context, span trace.Span, chain *tasks.Chain)

AnnotateSpanWithChainInfo ...

func AnnotateSpanWithChordInfo

func AnnotateSpanWithChordInfo(ctx context.Context, span trace.Span, chord *tasks.Chord, sendConcurrency int)

AnnotateSpanWithChordInfo ...

func AnnotateSpanWithGroupInfo

func AnnotateSpanWithGroupInfo(ctx context.Context, span trace.Span, group *tasks.Group, sendConcurrency int)

AnnotateSpanWithGroupInfo ...

func AnnotateSpanWithSignatureInfo

func AnnotateSpanWithSignatureInfo(span trace.Span, signature *tasks.Signature)

AnnotateSpanWithSignatureInfo ...

func HeadersWithSpan

func HeadersWithSpan(ctx context.Context, headers http.Header) http.Header

HeadersWithSpan will inject a span into the signature headers

func StartSpanFromHeaders

func StartSpanFromHeaders(ctx context.Context, headers http.Header, operationName string) (_spanCtx context.Context, _span trace.Span)

StartSpanFromHeaders will extract a span from the signature headers and start a new span with the given operation name.