tracer

package

Go to main page

Versions in this module

v0

v0.10.0

Apr 20, 2022

Changes in this version

+ const ZipkinFlagsKey

+ const ZipkinParentSpanIdKey

+ const ZipkinSampledKey

+ const ZipkinSpanIdKey

+ const ZipkinTraceIdKey

+ var ErrInvalidZipkinSampled = errors.New(fmt.Sprintf("invalid %s found", ZipkinSampledKey))

+ var ErrInvalidZipkinSpanId = fmt.Errorf("%w. Invalid %s found", opentracing.ErrSpanContextCorrupted, ZipkinSpanIdKey)

+ var ErrInvalidZipkinTraceId = fmt.Errorf("%w. Invalid %s found", opentracing.ErrSpanContextCorrupted, ZipkinTraceIdKey)

type Option

+ func WithZipkinPropagator(zipkinOptions ...ZipkinOption) Option

+ type ZipkinOption func(*ZipkinWavefrontPropagator)

+ func WithOverrideSamplingDecision(samplingDecision bool) ZipkinOption

+ type ZipkinWavefrontPropagator struct

+ func NewZipkinWavefrontPropagator(opts ...ZipkinOption) *ZipkinWavefrontPropagator

+ func (z *ZipkinWavefrontPropagator) Extract(opaqueCarrier interface{}) (SpanContext, error)

+ func (z *ZipkinWavefrontPropagator) Inject(spanContext opentracing.SpanContext, opaqueCarrier interface{}) error

v0.9.3

Sep 14, 2021

Changes in this version

type Option

+ func WithGenerator(generator Generator) Option

v0.9.2

Aug 10, 2021

Changes in this version

+ func FromUUID(id string) string

+ type Generator interface

+ SpanID func() string

+ TraceID func() string

+ func NewGeneratorUUID() Generator

+ func NewGeneratorW3C() Generator

+ type GeneratorUUID struct

+ func (g *GeneratorUUID) SpanID() string

+ func (g *GeneratorUUID) TraceID() string

+ type GeneratorW3C struct

+ func (g *GeneratorW3C) SpanID() string

+ func (g *GeneratorW3C) TraceID() string

type Option

+ func WithW3CGenerator() Option

+ func WithW3CPropagator() Option

+ type PropagatorW3C struct

+ func (p *PropagatorW3C) Extract(opaqueCarrier interface{}) (opentracing.SpanContext, error)

+ func (p *PropagatorW3C) Inject(spanContext opentracing.SpanContext, opaqueCarrier interface{}) error

+ type SpanContextPropagator interface

+ Extract func(carrier interface{}) (opentracing.SpanContext, error)

+ Inject func(spanContext opentracing.SpanContext, carrier interface{}) error

+ func NewPropagatorW3C() SpanContextPropagator

v0.9.1

Feb 11, 2021

v0.9.0

Jun 19, 2020

Changes in this version

+ const BAGGAGE_PREFIX

+ const PARENT_ID_KEY

+ const SAMPLING_DECISION_KEY

+ const TRACE_ID_KEY

+ var Delegator delegatorType

+ func New(reporter SpanReporter, options ...Option) opentracing.Tracer

+ func ToUUID(id string) (string, error)

+ type CountingReporter int32

+ func (c *CountingReporter) Close() error

+ func (c *CountingReporter) ReportSpan(r RawSpan)

+ type DelegatingCarrier interface

+ GetBaggage func(func(key, value string))

+ SetBaggageItem func(key, value string)

+ SetState func(traceID string, spanID string, sampled bool)

+ State func() (traceID string, spanID string, sampled bool)

+ type DurationSampler struct

+ Duration time.Duration

+ func (t DurationSampler) IsEarly() bool

+ func (t DurationSampler) ShouldSample(span RawSpan) bool

+ type InMemorySpanReporter struct

+ func NewInMemoryReporter() *InMemorySpanReporter

+ func (r *InMemorySpanReporter) Close() error

+ func (r *InMemorySpanReporter) ReportSpan(span RawSpan)

+ func (r *InMemorySpanReporter) Reset()

+ type JaegerOption func(*JaegerWavefrontPropagator)

+ func WithBaggagePrefix(baggagePrefix string) JaegerOption

+ func WithTraceIdHeader(traceIdHeader string) JaegerOption

+ type JaegerWavefrontPropagator struct

+ func NewJaegerWavefrontPropagator(tracer *WavefrontTracer, options []JaegerOption) *JaegerWavefrontPropagator

+ func (p *JaegerWavefrontPropagator) Extract(opaqueCarrier interface{}) (SpanContext, error)

+ func (p *JaegerWavefrontPropagator) Inject(spanContext opentracing.SpanContext, opaqueCarrier interface{}) error

+ type NeverSample struct

+ func (t NeverSample) IsEarly() bool

+ func (t NeverSample) ShouldSample(span RawSpan) bool

+ type Option func(*WavefrontTracer)

+ func WithJaegerPropagator(traceId, baggagePrefix string) Option

+ func WithSampler(sampler Sampler) Option

+ type RateSampler struct

+ Rate uint64

+ func (t RateSampler) IsEarly() bool

+ func (t RateSampler) ShouldSample(span RawSpan) bool

+ type RawSpan struct

+ Component string

+ Context SpanContext

+ Duration time.Duration

+ Logs []opentracing.LogRecord

+ Operation string

+ ParentSpanID string

+ References []opentracing.SpanReference

+ Start time.Time

+ Tags opentracing.Tags

+ type Sampler interface

+ IsEarly func() bool

+ ShouldSample func(span RawSpan) bool

+ type SpanContext struct

+ Baggage map[string]string

+ Sampled *bool

+ SpanID string

+ TraceID string

+ func (c SpanContext) ForeachBaggageItem(handler func(k, v string) bool)

+ func (c SpanContext) IsSampled() bool

+ func (c SpanContext) SamplingDecision() *bool

+ func (c SpanContext) WithBaggageItem(key, val string) SpanContext

+ type SpanReporter interface

+ ReportSpan func(span RawSpan)

+ type WavefrontTracer struct

+ func (t *WavefrontTracer) Extract(format interface{}, carrier interface{}) (opentracing.SpanContext, error)

+ func (t *WavefrontTracer) Inject(sc opentracing.SpanContext, format interface{}, carrier interface{}) error

+ func (t *WavefrontTracer) StartSpan(operationName string, opts ...opentracing.StartSpanOption) opentracing.Span

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