sampling

Documentation

Overview

Package sampling contains the interfaces and data types used to implement the various sampling policies.

Copyright The OpenTelemetry Authors SPDX-License-Identifier: Apache-2.0

Index

• func IsInvertDecisionsDisabled() bool
• func SetAttrOnScopeSpans(data *TraceData, attrName string, attrKey string)
• type And
  • func (c *And) Evaluate(ctx context.Context, traceID pcommon.TraceID, trace *TraceData) (Decision, error)
• type Composite
  • func (c *Composite) Evaluate(ctx context.Context, traceID pcommon.TraceID, trace *TraceData) (Decision, error)
• type Decision
• type Drop
  • func (c *Drop) Evaluate(ctx context.Context, traceID pcommon.TraceID, trace *TraceData) (Decision, error)
• type MonotonicClock
• type PolicyEvaluator
  • func NewAlwaysSample(settings component.TelemetrySettings) PolicyEvaluator
  • func NewAnd(logger *zap.Logger, subpolicies []PolicyEvaluator) PolicyEvaluator
  • func NewBooleanAttributeFilter(settings component.TelemetrySettings, key string, value bool, invertMatch bool) PolicyEvaluator
  • func NewComposite(logger *zap.Logger, maxTotalSpansPerSecond int64, ...) PolicyEvaluator
  • func NewDrop(logger *zap.Logger, subpolicies []PolicyEvaluator) PolicyEvaluator
  • func NewLatency(settings component.TelemetrySettings, thresholdMs int64, ...) PolicyEvaluator
  • func NewNumericAttributeFilter(settings component.TelemetrySettings, key string, minValue, maxValue *int64, ...) PolicyEvaluator
  • func NewOTTLConditionFilter(settings component.TelemetrySettings, ...) (PolicyEvaluator, error)
  • func NewProbabilisticSampler(settings component.TelemetrySettings, hashSalt string, ...) PolicyEvaluator
  • func NewRateLimiting(settings component.TelemetrySettings, spansPerSecond int64) PolicyEvaluator
  • func NewSpanCount(settings component.TelemetrySettings, minSpans, maxSpans int32) PolicyEvaluator
  • func NewStatusCodeFilter(settings component.TelemetrySettings, statusCodeString []string) (PolicyEvaluator, error)
  • func NewStringAttributeFilter(settings component.TelemetrySettings, key string, values []string, ...) PolicyEvaluator
  • func NewTraceStateFilter(settings component.TelemetrySettings, key string, values []string) PolicyEvaluator
• type SubPolicyEvalParams
• type TimeProvider
• type TraceData

Functions

func IsInvertDecisionsDisabled

func IsInvertDecisionsDisabled() bool

func SetAttrOnScopeSpans

func SetAttrOnScopeSpans(data *TraceData, attrName string, attrKey string)

Types

type And

type And struct {
	// contains filtered or unexported fields
}

func (*And) Evaluate

func (c *And) Evaluate(ctx context.Context, traceID pcommon.TraceID, trace *TraceData) (Decision, error)

Evaluate looks at the trace data and returns a corresponding SamplingDecision.

type Composite

type Composite struct {
	// contains filtered or unexported fields
}

Composite evaluator and its internal data

func (*Composite) Evaluate

func (c *Composite) Evaluate(ctx context.Context, traceID pcommon.TraceID, trace *TraceData) (Decision, error)

Evaluate looks at the trace data and returns a corresponding SamplingDecision.

type Decision

type Decision int32

Decision gives the status of sampling decision.

const (
	// Unspecified indicates that the status of the decision was not set yet.
	Unspecified Decision = iota
	// Pending indicates that the policy was not evaluated yet.
	Pending
	// Sampled is used to indicate that the decision was already taken
	// to sample the data.
	Sampled
	// NotSampled is used to indicate that the decision was already taken
	// to not sample the data.
	NotSampled
	// Dropped is used to indicate that a trace should be dropped regardless of
	// all other decisions.
	Dropped
	// Error is used to indicate that policy evaluation was not succeeded.
	Error
	// InvertSampled is used on the invert match flow and indicates to sample
	// the data.
	InvertSampled
	// InvertNotSampled is used on the invert match flow and indicates to not
	// sample the data.
	InvertNotSampled
)

type Drop

type Drop struct {
	// contains filtered or unexported fields
}

func (*Drop) Evaluate

func (c *Drop) Evaluate(ctx context.Context, traceID pcommon.TraceID, trace *TraceData) (Decision, error)

Evaluate looks at the trace data and returns a corresponding SamplingDecision.

type MonotonicClock

type MonotonicClock struct{}

MonotonicClock provides monotonic real clock-based current Unix second. Use it when creating a NewComposite which should measure sample rates against a realtime clock (this is almost always what you want to do, the exception is usually only automated testing where you may want to have fake clocks).

type PolicyEvaluator

type PolicyEvaluator interface {
	// Evaluate looks at the trace data and returns a corresponding SamplingDecision.
	Evaluate(ctx context.Context, traceID pcommon.TraceID, trace *TraceData) (Decision, error)
}

PolicyEvaluator implements a tail-based sampling policy evaluator, which makes a sampling decision for a given trace when requested.

func NewAlwaysSample

func NewAlwaysSample(settings component.TelemetrySettings) PolicyEvaluator

NewAlwaysSample creates a policy evaluator the samples all traces.

func NewAnd

func NewAnd(
	logger *zap.Logger,
	subpolicies []PolicyEvaluator,
) PolicyEvaluator

func NewBooleanAttributeFilter

func NewBooleanAttributeFilter(settings component.TelemetrySettings, key string, value bool, invertMatch bool) PolicyEvaluator

NewBooleanAttributeFilter creates a policy evaluator that samples all traces with the given attribute that match the supplied boolean value.

func NewComposite

func NewComposite(
	logger *zap.Logger,
	maxTotalSpansPerSecond int64,
	subPolicyParams []SubPolicyEvalParams,
	timeProvider TimeProvider,
	recordSubPolicy bool,
) PolicyEvaluator

NewComposite creates a policy evaluator that samples all subpolicies.

func NewDrop

func NewDrop(
	logger *zap.Logger,
	subpolicies []PolicyEvaluator,
) PolicyEvaluator

func NewLatency

func NewLatency(settings component.TelemetrySettings, thresholdMs int64, upperThresholdMs int64) PolicyEvaluator

NewLatency creates a policy evaluator sampling traces with a duration greater than a configured threshold

func NewNumericAttributeFilter

func NewNumericAttributeFilter(settings component.TelemetrySettings, key string, minValue, maxValue *int64, invertMatch bool) PolicyEvaluator

NewNumericAttributeFilter creates a policy evaluator that samples all traces with the given attribute in the given numeric range. If minValue is nil, it will use math.MinInt64. If maxValue is nil, it will use math.MaxInt64. At least one of minValue or maxValue must be set.

func NewOTTLConditionFilter

func NewOTTLConditionFilter(settings component.TelemetrySettings, spanConditions, spanEventConditions []string, errMode ottl.ErrorMode) (PolicyEvaluator, error)

NewOTTLConditionFilter looks at the trace data and returns a corresponding SamplingDecision.

func NewProbabilisticSampler

func NewProbabilisticSampler(settings component.TelemetrySettings, hashSalt string, samplingPercentage float64) PolicyEvaluator

NewProbabilisticSampler creates a policy evaluator that samples a percentage of traces.

func NewRateLimiting

func NewRateLimiting(settings component.TelemetrySettings, spansPerSecond int64) PolicyEvaluator

NewRateLimiting creates a policy evaluator the samples all traces.

func NewSpanCount

func NewSpanCount(settings component.TelemetrySettings, minSpans, maxSpans int32) PolicyEvaluator

NewSpanCount creates a policy evaluator sampling traces with more than one span per trace

func NewStatusCodeFilter

func NewStatusCodeFilter(settings component.TelemetrySettings, statusCodeString []string) (PolicyEvaluator, error)

NewStatusCodeFilter creates a policy evaluator that samples all traces with a given status code.

func NewStringAttributeFilter

func NewStringAttributeFilter(settings component.TelemetrySettings, key string, values []string, regexMatchEnabled bool, evictSize int, invertMatch bool) PolicyEvaluator

NewStringAttributeFilter creates a policy evaluator that samples all traces with the given attribute in the given numeric range.

func NewTraceStateFilter

func NewTraceStateFilter(settings component.TelemetrySettings, key string, values []string) PolicyEvaluator

NewTraceStateFilter creates a policy evaluator that samples all traces with the given value by the specific key in the trace_state.

type SubPolicyEvalParams

type SubPolicyEvalParams struct {
	Evaluator         PolicyEvaluator
	MaxSpansPerSecond int64
	Name              string
}

SubPolicyEvalParams defines the evaluator and max rate for a sub-policy

type TimeProvider

type TimeProvider interface {
	// contains filtered or unexported methods
}

TimeProvider allows to get current Unix second

type TraceData

type TraceData struct {
	sync.Mutex
	// Arrival time the first span for the trace was received.
	ArrivalTime time.Time
	// Decisiontime time when sampling decision was taken.
	DecisionTime time.Time
	// SpanCount track the number of spans on the trace.
	SpanCount *atomic.Int64
	// ReceivedBatches stores all the batches received for the trace.
	ReceivedBatches ptrace.Traces
	// FinalDecision.
	FinalDecision Decision
}

TraceData stores the sampling related trace data.