cardinalitycontrol

package

v0.103.0 Latest Latest Go to latest Published: Nov 11, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation ¶

Index ¶

Constants
func RegisterDefaultHashFuncs(cms *CountMinSketch)
type CountMinSketch
- func NewCountMinSketch(depth, width int, hashFuncs ...CountMinSketchHashFunc) *CountMinSketch
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"
)

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

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