The highest tagged major version is v2.

tracing

package

v1.10.8 Latest Latest Go to latest Published: Mar 19, 2024 License: MPL-2.0 Imports: 5 Imported by: 13

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/RichardKnop/machinery

Links

Open Source Insights

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)

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.

Source Files ¶

View all Source files

tracing.go

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