tracing

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

Variables

var (
	MachineryTag     = opentracing.Tag{Key: string(opentracing_ext.Component), Value: "millstone"}
	WorkflowGroupTag = opentracing.Tag{Key: "millstone.workflow", Value: "group"}
	WorkflowChordTag = opentracing.Tag{Key: "millstone.workflow", Value: "chord"}
	WorkflowChainTag = opentracing.Tag{Key: "millstone.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.