sampler

May 16, 2024

Changes in this version

+ type ProbabilisticSampler struct

+ func NewProbabilisticSampler(conf *config.AgentConfig, statsd statsd.ClientInterface) *ProbabilisticSampler

+ func (ps *ProbabilisticSampler) Sample(root *trace.Span) bool

+ func (ps *ProbabilisticSampler) Start()

+ func (ps *ProbabilisticSampler) Stop()

Oct 31, 2023

Changes in this version

+ func SingleSpanSampling(pt *traceutil.ProcessedTrace) bool

Jan 18, 2023

Changes in this version

type PrioritySampler

+ func (s *PrioritySampler) GetTargetTPS() float64

+ func (s *PrioritySampler) UpdateTargetTPS(targetTPS float64)

type RareSampler

+ func (e *RareSampler) IsEnabled() bool

+ func (e *RareSampler) SetEnabled(enabled bool)

type ScoreSampler

+ func (s *ScoreSampler) GetTargetTPS() float64

+ func (s *ScoreSampler) UpdateTargetTPS(targetTPS float64)

Oct 31, 2022

Changes in this version

+ const KeySpanSamplingMechanism

+ func ApplySpanSampling(chunk *pb.TraceChunk) bool

May 23, 2022

Changes in this version

+ const KeyAnalyzedSpans

+ const KeyErrorType

+ const KeyHTTPStatusCode

+ const KeySamplingRateClient

+ const KeySamplingRateEventExtraction

+ const KeySamplingRateGlobal

+ const KeySamplingRateMaxEPSSampler

+ const KeySamplingRatePreSampler

+ func GetClientRate(s *pb.Span) float64

+ func GetEventExtractionRate(s *pb.Span) float64

+ func GetGlobalRate(s *pb.Span) float64

+ func GetMaxEPSRate(s *pb.Span) float64

+ func GetPreSampleRate(s *pb.Span) float64

+ func IsAnalyzedSpan(s *pb.Span) bool

+ func SampleByRate(traceID uint64, rate float64) bool

+ func SetAnalyzedSpan(s *pb.Span)

+ func SetClientRate(s *pb.Span, rate float64)

+ func SetEventExtractionRate(s *pb.Span, rate float64)

+ func SetMaxEPSRate(s *pb.Span, rate float64)

+ func SetPreSampleRate(s *pb.Span, rate float64)

+ type DynamicConfig struct

+ RateByService RateByService

+ func NewDynamicConfig() *DynamicConfig

+ type ErrorsSampler struct

+ func NewErrorsSampler(conf *config.AgentConfig) *ErrorsSampler

+ type NoPrioritySampler struct

+ func NewNoPrioritySampler(conf *config.AgentConfig) *NoPrioritySampler

+ type PrioritySampler struct

+ func NewPrioritySampler(conf *config.AgentConfig, dynConf *DynamicConfig) *PrioritySampler

+ func (s *PrioritySampler) Sample(now time.Time, trace *pb.TraceChunk, root *pb.Span, tracerEnv string, ...) bool

+ func (s *PrioritySampler) Start()

+ func (s *PrioritySampler) Stop()

+ type RareSampler struct

+ func NewRareSampler() *RareSampler

+ func (e *RareSampler) Sample(now time.Time, t *pb.TraceChunk, env string) bool

+ func (e *RareSampler) Stop()

+ type RateByService struct

+ func (rbs *RateByService) GetNewState(version string) State

+ func (rbs *RateByService) SetAll(rates map[ServiceSignature]rm)

+ type RemoteRates struct

+ func (r *RemoteRates) Start()

+ func (r *RemoteRates) Stop()

+ type Sampler struct

+ func (s *Sampler) Start()

+ func (s *Sampler) Stop()

+ type SamplingPriority int8

+ const PriorityAutoDrop

+ const PriorityAutoKeep

+ const PriorityNone

+ const PriorityUserDrop

+ const PriorityUserKeep

+ func GetSamplingPriority(t *pb.TraceChunk) (SamplingPriority, bool)

+ type ScoreSampler struct

+ func (s *ScoreSampler) Sample(now time.Time, trace pb.Trace, root *pb.Span, env string) bool

+ type ServiceSignature struct

+ Env string

+ Name string

+ func (s ServiceSignature) Hash() Signature

+ func (s ServiceSignature) String() string

+ type Signature uint64

+ type State struct

+ Mechanisms map[string]apmsampling.SamplingMechanism

+ Rates map[string]float64

+ Version string