filter

Documentation

Index

• type Item
• type ItemFilter
  • func NewItemCardinalityFilter(metricName string, totalLimit int, limitByTimestamp int, ...) (ItemFilter, error)
  • func NewNopItemCardinalityFilter() ItemFilter
• type ItemFilterResolver
  • func NewNopItemFilterResolver() ItemFilterResolver

Types

type Item

type Item struct {
	SeriesKey string
	Timestamp time.Time
}

type ItemFilter

type ItemFilter interface {
	Filter(source []*Item) ([]*Item, error)
	Shutdown() error
	TotalLimit() int
	LimitByTimestamp() int
}

func NewItemCardinalityFilter

func NewItemCardinalityFilter(metricName string, totalLimit int, limitByTimestamp int,
	itemActivityPeriod time.Duration, logger *zap.Logger) (ItemFilter, error)

func NewNopItemCardinalityFilter

func NewNopItemCardinalityFilter() ItemFilter

type ItemFilterResolver

type ItemFilterResolver interface {
	Resolve(metricFullName string) (ItemFilter, error)
	Shutdown() error
}

func NewNopItemFilterResolver

func NewNopItemFilterResolver() ItemFilterResolver