filter

Documentation

Index

• type Config
• type PatternStorage
  • func NewPatternStorage(database moira.Database, metrics *graphite.FilterMetrics, logger moira.Logger) (*PatternStorage, error)
  • func (storage *PatternStorage) ProcessIncomingMetric(lineBytes []byte) *moira.MatchedMetric
  • func (storage *PatternStorage) RefreshTree() error
• type Storage
  • func NewCacheStorage(logger moira.Logger, metrics *graphite.FilterMetrics, reader io.Reader) (*Storage, error)
  • func (storage *Storage) EnrichMatchedMetric(buffer map[string]*moira.MatchedMetric, m *moira.MatchedMetric)

Types

type Config

type Config struct {
	Enabled         bool
	Listen          string
	RetentionConfig string
}

Config is filter configuration settings

type PatternStorage

type PatternStorage struct {
	PatternTree *patternNode
	// contains filtered or unexported fields
}

PatternStorage contains pattern tree

func NewPatternStorage

func NewPatternStorage(database moira.Database, metrics *graphite.FilterMetrics, logger moira.Logger) (*PatternStorage, error)

NewPatternStorage creates new PatternStorage struct

func (*PatternStorage) ProcessIncomingMetric

func (storage *PatternStorage) ProcessIncomingMetric(lineBytes []byte) *moira.MatchedMetric

ProcessIncomingMetric validates, parses and matches incoming raw string

func (*PatternStorage) RefreshTree

func (storage *PatternStorage) RefreshTree() error

RefreshTree builds pattern tree from redis data

type Storage

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

Storage struct to store retention matchers

func NewCacheStorage

func NewCacheStorage(logger moira.Logger, metrics *graphite.FilterMetrics, reader io.Reader) (*Storage, error)

NewCacheStorage create new Storage

func (*Storage) EnrichMatchedMetric

func (storage *Storage) EnrichMatchedMetric(buffer map[string]*moira.MatchedMetric, m *moira.MatchedMetric)

EnrichMatchedMetric calculate retention and filter cached values