Documentation ¶
Index ¶
- Variables
- func AnnotateSpanWithChainInfo(span opentracing.Span, chain *tasks.Chain)
- func AnnotateSpanWithChordInfo(span opentracing.Span, chord *tasks.Chord, sendConcurrency int)
- func AnnotateSpanWithGroupInfo(span opentracing.Span, group *tasks.Group, sendConcurrency int)
- func AnnotateSpanWithSignatureInfo(span opentracing.Span, signature *tasks.Signature)
- func ConsumerOption(producer opentracing.SpanContext) opentracing.StartSpanOption
- func HeadersWithSpan(headers tasks.Headers, span opentracing.Span) tasks.Headers
- func ProducerOption() opentracing.StartSpanOption
- func StartSpanFromHeaders(headers tasks.Headers, operationName string) opentracing.Span
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)
func AnnotateSpanWithChordInfo ¶
func AnnotateSpanWithChordInfo(span opentracing.Span, chord *tasks.Chord, sendConcurrency int)
func AnnotateSpanWithGroupInfo ¶
func AnnotateSpanWithGroupInfo(span opentracing.Span, group *tasks.Group, sendConcurrency int)
func AnnotateSpanWithSignatureInfo ¶
func AnnotateSpanWithSignatureInfo(span opentracing.Span, signature *tasks.Signature)
func ConsumerOption ¶
func ConsumerOption(producer opentracing.SpanContext) opentracing.StartSpanOption
func HeadersWithSpan ¶
HeadersWithSpan will inject a span into the signature headers
func ProducerOption ¶
func ProducerOption() opentracing.StartSpanOption
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.
Click to show internal directories.
Click to hide internal directories.