instrumenter

package

Go to main page

Versions in this module

v0

v0.7.0

Jan 7, 2025

v0.6.0

Dec 18, 2024

Changes in this version

type Instrumenter

+ ShouldStart func(parentContext context.Context, request REQUEST) bool

type InternalInstrumenter

+ func (i *InternalInstrumenter[REQUEST, RESPONSE]) ShouldStart(parentContext context.Context, request REQUEST) bool

+ type NoneStrategy struct

type PropagatingFromUpstreamInstrumenter

+ func (p *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]) ShouldStart(parentContext context.Context, request REQUEST) bool

type PropagatingToDownstreamInstrumenter

+ func (p *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]) ShouldStart(parentContext context.Context, request REQUEST) bool

+ type SemConvStrategy struct

+ type SpanKindStrategy struct

+ type SpanKindSuppressor struct

+ func NewSpanKindSuppressor() *SpanKindSuppressor

+ func (s *SpanKindSuppressor) ShouldSuppress(parentContext context.Context, spanKind trace.SpanKind) bool

+ func (s *SpanKindSuppressor) StoreInContext(context context.Context, spanKind trace.SpanKind, span trace.Span) context.Context

+ type SpanSuppressorStrategy interface

v0.5.0

Dec 13, 2024

v0.4.1

Nov 25, 2024

v0.4.0

Nov 23, 2024

Changes in this version

+ func GetCachedAttrs() []attribute.KeyValue

+ func PutCachedAttrs(attrs []attribute.KeyValue)

type Builder

+ Scope instrumentation.Scope

+ func (b *Builder[REQUEST, RESPONSE]) SetInstrumentationScope(scope instrumentation.Scope) *Builder[REQUEST, RESPONSE]

type InstrumentEnabler

+ Enable func() bool

type Instrumenter

+ StartAndEndWithOptions func(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

type InternalInstrumenter

+ func (i *InternalInstrumenter[REQUEST, RESPONSE]) StartAndEndWithOptions(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

type PropagatingFromUpstreamInstrumenter

+ func (p *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]) StartAndEndWithOptions(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

type PropagatingToDownstreamInstrumenter

+ func (p *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]) StartAndEndWithOptions(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

v0.3.0

Oct 25, 2024

v0.2.0

Sep 28, 2024

v0.0.2

Sep 28, 2024

Changes in this version

type Builder

+ func (b *Builder[REQUEST, RESPONSE]) BuildPropagatingFromUpstreamInstrumenterWithProp(carrierGetter func(REQUEST) propagation.TextMapCarrier, ...) *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) BuildPropagatingToDownstreamInstrumenterWithProp(carrierGetter func(REQUEST) propagation.TextMapCarrier, ...) *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]

type Instrumenter

+ StartAndEnd func(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

+ type InternalInstrumenter struct

+ func (i *InternalInstrumenter[REQUEST, RESPONSE]) End(ctx context.Context, request REQUEST, response RESPONSE, err error)

+ func (i *InternalInstrumenter[REQUEST, RESPONSE]) Start(parentContext context.Context, request REQUEST) context.Context

+ func (i *InternalInstrumenter[REQUEST, RESPONSE]) StartAndEnd(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

type PropagatingFromUpstreamInstrumenter

+ func (p *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]) StartAndEnd(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

type PropagatingToDownstreamInstrumenter

+ func (p *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]) StartAndEnd(parentContext context.Context, request REQUEST, response RESPONSE, err error, ...)

v0.0.1

Aug 15, 2024

Changes in this version

+ type AlwaysClientExtractor struct

+ func (a *AlwaysClientExtractor[any]) Extract(request any) trace.SpanKind

+ type AlwaysConsumerExtractor struct

+ func (a *AlwaysConsumerExtractor[any]) Extract(request any) trace.SpanKind

+ type AlwaysInternalExtractor struct

+ func (a *AlwaysInternalExtractor[any]) Extract(request any) trace.SpanKind

+ type AlwaysProducerExtractor struct

+ func (a *AlwaysProducerExtractor[any]) Extract(request any) trace.SpanKind

+ type AlwaysServerExtractor struct

+ func (a *AlwaysServerExtractor[any]) Extract(request any) trace.SpanKind

+ type AttributesExtractor interface

+ OnEnd func(attributes []attribute.KeyValue, context context.Context, request REQUEST, ...) []attribute.KeyValue

+ OnStart func(attributes []attribute.KeyValue, parentContext context.Context, ...) []attribute.KeyValue

+ type AttrsShadower interface

+ Shadow func(attrs []attribute.KeyValue) (int, []attribute.KeyValue)

+ type Builder struct

+ AttributesExtractors []AttributesExtractor[REQUEST, RESPONSE]

+ ContextCustomizers []ContextCustomizer[REQUEST]

+ Enabler InstrumentEnabler

+ InstVersion string

+ OperationListeners []*OperationListenerWrapper

+ OperationMetrics []OperationMetrics

+ SpanKindExtractor SpanKindExtractor[REQUEST]

+ SpanNameExtractor SpanNameExtractor[REQUEST]

+ SpanStatusExtractor SpanStatusExtractor[REQUEST, RESPONSE]

+ SpanSuppressor SpanSuppressor

+ Tracer trace.Tracer

+ func (b *Builder[REQUEST, RESPONSE]) AddAttributesExtractor(attributesExtractor ...AttributesExtractor[REQUEST, RESPONSE]) *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) AddContextCustomizers(contextCustomizers ...ContextCustomizer[REQUEST]) *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) AddOperationListeners(operationListener ...*OperationListenerWrapper) *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) BuildInstrumenter() *Instrumenter[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) BuildPropagatingFromUpstreamInstrumenter(carrierGetter func(REQUEST) propagation.TextMapCarrier, ...) *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) BuildPropagatingToDownstreamInstrumenter(carrierGetter func(REQUEST) propagation.TextMapCarrier, ...) *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) Init() *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) SetInstVersion(instVersion string) *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) SetInstrumentEnabler(enabler InstrumentEnabler) *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) SetSpanKindExtractor(spanKindExtractor SpanKindExtractor[REQUEST]) *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) SetSpanNameExtractor(spanNameExtractor SpanNameExtractor[REQUEST]) *Builder[REQUEST, RESPONSE]

+ func (b *Builder[REQUEST, RESPONSE]) SetSpanStatusExtractor(spanStatusExtractor SpanStatusExtractor[REQUEST, RESPONSE]) *Builder[REQUEST, RESPONSE]

+ type ContextCustomizer interface

+ OnStart func(context context.Context, request REQUEST, startAttributes []attribute.KeyValue) context.Context

+ type InstrumentEnabler interface

+ IsEnabled func() bool

+ func NewDefaultInstrumentEnabler() InstrumentEnabler

+ type Instrumenter struct

+ func (i *Instrumenter[REQUEST, RESPONSE]) End(ctx context.Context, request REQUEST, response RESPONSE, err error)

+ func (i *Instrumenter[REQUEST, RESPONSE]) Start(parentContext context.Context, request REQUEST) context.Context

+ type NoopAttrsShadower struct

+ func (n NoopAttrsShadower) Shadow(attrs []attribute.KeyValue) (int, []attribute.KeyValue)

+ type NoopSpanSuppressor struct

+ func NewNoopSpanSuppressor() *NoopSpanSuppressor

+ func (n *NoopSpanSuppressor) ShouldSuppress(parentContext context.Context, spanKind trace.SpanKind) bool

+ func (n *NoopSpanSuppressor) StoreInContext(context context.Context, spanKind trace.SpanKind, span trace.Span) context.Context

+ type OperationListener interface

+ OnAfterEnd func(context context.Context, endAttributes []attribute.KeyValue, ...)

+ OnAfterStart func(context context.Context, endTimestamp time.Time)

+ OnBeforeEnd func(context context.Context, startAttributes []attribute.KeyValue, ...) context.Context

+ OnBeforeStart func(parentContext context.Context, startTimestamp time.Time) context.Context

+ type OperationListenerWrapper struct

+ func (w *OperationListenerWrapper) OnAfterEnd(context context.Context, endAttributes []attribute.KeyValue, ...)

+ func (w *OperationListenerWrapper) OnAfterStart(context context.Context, endTimestamp time.Time)

+ func (w *OperationListenerWrapper) OnBeforeEnd(context context.Context, startAttributes []attribute.KeyValue, ...) context.Context

+ func (w *OperationListenerWrapper) OnBeforeStart(parentContext context.Context, startTimestamp time.Time) context.Context

+ type OperationMetrics interface

+ Create func(meter metric.Meter) *OperationListenerWrapper

+ Match func(meta meter.MeterMeta) bool

+ type PropagatingFromUpstreamInstrumenter struct

+ func (p *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]) End(ctx context.Context, request REQUEST, response RESPONSE, err error)

+ func (p *PropagatingFromUpstreamInstrumenter[REQUEST, RESPONSE]) Start(parentContext context.Context, request REQUEST) context.Context

+ type PropagatingToDownstreamInstrumenter struct

+ func (p *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]) End(ctx context.Context, request REQUEST, response RESPONSE, err error)

+ func (p *PropagatingToDownstreamInstrumenter[REQUEST, RESPONSE]) Start(parentContext context.Context, request REQUEST) context.Context

+ type SpanKeyProvider interface

+ GetSpanKey func() attribute.Key

+ type SpanKeySuppressor struct

+ func NewSpanKeySuppressor(spanKeys []attribute.Key) *SpanKeySuppressor

+ func (s *SpanKeySuppressor) ShouldSuppress(parentContext context.Context, spanKind trace.SpanKind) bool

+ func (s *SpanKeySuppressor) StoreInContext(ctx context.Context, spanKind trace.SpanKind, span trace.Span) context.Context

+ type SpanKindExtractor interface

+ Extract func(request REQUEST) trace.SpanKind

+ type SpanNameExtractor interface

+ Extract func(request REQUEST) string

+ type SpanStatusExtractor interface

+ Extract func(span trace.Span, request REQUEST, response RESPONSE, err error)

+ type SpanSuppressor interface

+ ShouldSuppress func(parentContext context.Context, spanKind trace.SpanKind) bool

+ StoreInContext func(context context.Context, spanKind trace.SpanKind, span trace.Span) context.Context

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