cardinalitycontrol

Documentation

Index

• Constants
• func RegisterDefaultHashFuncs(cms *CountMinSketch)
• type CountMinSketch
  • 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
• type CountMinSketchHashFunc
• type Limiter
  • func NewMetricsLimiter(config *config.LimiterConfig, logger *zap.Logger) Limiter
• type MetricData
  • func (m MetricData) Frequency() int
  • func (m MetricData) HashKey() string
• type MetricsLimiter
  • func (m *MetricsLimiter) Admit(metricName string, attributes, resourceAttributes pcommon.Map) (bool, error)

Constants

const (
	UnprocessedServiceOperationValue       = "AllOtherOperations"
	UnprocessedRemoteServiceOperationValue = "AllOtherRemoteOperations"
)

Functions

func RegisterDefaultHashFuncs

func RegisterDefaultHashFuncs(cms *CountMinSketch)

Types

type CountMinSketch

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

func NewCountMinSketch

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

func (*CountMinSketch) Get

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

func (*CountMinSketch) Insert

func (cms *CountMinSketch) Insert(obj CountMinSketchEntry)

func (*CountMinSketch) RegisterHashFunc

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

type CountMinSketchEntry

type CountMinSketchEntry interface {
	HashKey() string
	Frequency() int
}

type CountMinSketchHashFunc

type CountMinSketchHashFunc func(hashKey string) int64

type Limiter

type Limiter interface {
	Admit(name string, attributes, resourceAttributes pcommon.Map) (bool, error)
}

func NewMetricsLimiter

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

type MetricData

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

MetricData represents a key-value pair.

func (MetricData) Frequency

func (m MetricData) Frequency() int

func (MetricData) HashKey

func (m MetricData) HashKey() string

type MetricsLimiter

type MetricsLimiter struct {
	DropThreshold     int
	LogDroppedMetrics bool
	RotationInterval  time.Duration
	// contains filtered or unexported fields
}

func (*MetricsLimiter) Admit

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