cardinalitycontrol

Mar 1, 2024

Changes in this version

+ const UnprocessedRemoteServiceOperationValue

+ const UnprocessedServiceOperationValue

Jan 31, 2024

Changes in this version

+ const UnprocessedMetricValue

+ func RegisterDefaultHashFuncs(cms *CountMinSketch)

+ type CountMinSketch struct

+ func NewCountMinSketch(depth, width int, hashFuncs ...CountMinSketchHashFunc) *CountMinSketch

+ func (cms *CountMinSketch) Get(obj CountMinSketchEntry) int

+ func (cms *CountMinSketch) Insert(obj CountMinSketchEntry)

+ func (cms *CountMinSketch) RegisterHashFunc(hashFuncs ...CountMinSketchHashFunc)

+ type CountMinSketchEntry interface

+ Frequency func() int

+ HashKey func() string

+ type CountMinSketchHashFunc func(hashKey string) int64

+ type Limiter interface

+ Admit func(name string, attributes, resourceAttributes pcommon.Map) (bool, error)

+ func NewMetricsLimiter(config *config.LimiterConfig, logger *zap.Logger) Limiter

+ type MetricData struct

+ func (m MetricData) Frequency() int

+ func (m MetricData) HashKey() string

+ type MetricsLimiter struct

+ DropThreshold int

+ LogDroppedMetrics bool

+ RotationInterval time.Duration

+ func (m *MetricsLimiter) Admit(metricName string, attributes, resourceAttributes pcommon.Map) (bool, error)