tracing

package
v1.10.21 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: MPL-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	MachineryTag     = opentracing.Tag{Key: string(opentracing_ext.Component), Value: "machinery"}
	WorkflowGroupTag = opentracing.Tag{Key: "machinery.workflow", Value: "group"}
	WorkflowChordTag = opentracing.Tag{Key: "machinery.workflow", Value: "chord"}
	WorkflowChainTag = opentracing.Tag{Key: "machinery.workflow", Value: "chain"}
)

opentracing tags

Functions

func AnnotateSpanWithChainInfo

func AnnotateSpanWithChainInfo(span opentracing.Span, chain *tasks.Chain)

AnnotateSpanWithChainInfo ...

func AnnotateSpanWithChordInfo

func AnnotateSpanWithChordInfo(span opentracing.Span, chord *tasks.Chord, sendConcurrency int)

AnnotateSpanWithChordInfo ...

func AnnotateSpanWithGroupInfo

func AnnotateSpanWithGroupInfo(span opentracing.Span, group *tasks.Group, sendConcurrency int)

AnnotateSpanWithGroupInfo ...

func AnnotateSpanWithSignatureInfo

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

AnnotateSpanWithSignatureInfo ...

func ConsumerOption

func ConsumerOption(producer opentracing.SpanContext) opentracing.StartSpanOption

ConsumerOption ...

func HeadersWithSpan

func HeadersWithSpan(headers tasks.Headers, span opentracing.Span) tasks.Headers

HeadersWithSpan will inject a span into the signature headers

func ProducerOption

func ProducerOption() opentracing.StartSpanOption

ProducerOption ...

func StartSpanFromHeaders

func StartSpanFromHeaders(headers tasks.Headers, operationName string) opentracing.Span

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

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL