Documentation ¶
Index ¶
- Constants
- Variables
- func Format(ctx context.Context) zapcore.Field
- func Message(msg string) string
- func NewConsumerSpan(tracer trace.Tracer, header amqp.Table, typ string) (context.Context, trace.Span)
- type AMQPHeader
- type ExporterType
- type Headers
- type OTLPCompression
- type OTLPTracingBuilder
- type Traceparent
- type TracingBuilder
Constants ¶
View Source
const ( UNKNOWN_EXPORTER ExporterType = 0 OTLP_TLS_GRPC_EXPORTER ExporterType = 1 OTLP_GRPC_EXPORTER ExporterType = 2 OTLP_HTTPS_EXPORTER ExporterType = 3 JAEGER_EXPORTER ExporterType = 4 OTLP_GZIP_COMPRESSIONS OTLPCompression = "gzip" )
Variables ¶
View Source
var ( AMQPPropagator = propagation.NewCompositeTextMapPropagator( propagation.TraceContext{}, propagation.Baggage{}, ) )
Functions ¶
Types ¶
type AMQPHeader ¶
func (AMQPHeader) Get ¶
func (h AMQPHeader) Get(key string) string
func (AMQPHeader) Keys ¶
func (h AMQPHeader) Keys() []string
func (AMQPHeader) Set ¶
func (h AMQPHeader) Set(key, val string)
type ExporterType ¶
type ExporterType int32
type OTLPCompression ¶
type OTLPCompression string
type OTLPTracingBuilder ¶
type OTLPTracingBuilder interface { TracingBuilder WithAPIKeyHeader() OTLPTracingBuilder WithTimeout(t time.Duration) OTLPTracingBuilder WithReconnection(t time.Duration) OTLPTracingBuilder WithCompression(c OTLPCompression) OTLPTracingBuilder }
type Traceparent ¶
type TracingBuilder ¶
type TracingBuilder interface { AddHeader(key, value string) TracingBuilder WithHeaders(headers Headers) TracingBuilder Type(t ExporterType) TracingBuilder Endpoint(s string) TracingBuilder Build() (shutdown func(context.Context) error, err error) }
Click to show internal directories.
Click to hide internal directories.