patterns

Documentation

Index

• type Matcher
  • func NewMatcher(logger moira.Logger, metrics *graphite.FilterMetrics, ...) *Matcher
  • func (m *Matcher) Start(matchersCount int, lineChan <-chan []byte) chan *moira.MatchedMetric
• type RefreshPatternWorker
  • func NewRefreshPatternWorker(database moira.Database, metrics *graphite.FilterMetrics, logger moira.Logger, ...) *RefreshPatternWorker
  • func (worker *RefreshPatternWorker) Start() error
  • func (worker *RefreshPatternWorker) Stop() error

Types

type Matcher

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

Matcher checks metrics against known patterns

func NewMatcher

func NewMatcher(logger moira.Logger, metrics *graphite.FilterMetrics, patternsStorage *filter.PatternStorage) *Matcher

NewMatcher creates pattern matcher

func (*Matcher) Start

func (m *Matcher) Start(matchersCount int, lineChan <-chan []byte) chan *moira.MatchedMetric

Start spawns pattern matcher workers

type RefreshPatternWorker

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

RefreshPatternWorker realization

func NewRefreshPatternWorker

func NewRefreshPatternWorker(database moira.Database, metrics *graphite.FilterMetrics, logger moira.Logger, patternStorage *filter.PatternStorage) *RefreshPatternWorker

NewRefreshPatternWorker creates new RefreshPatternWorker

func (*RefreshPatternWorker) Start

func (worker *RefreshPatternWorker) Start() error

Start process to refresh pattern tree every second

func (*RefreshPatternWorker) Stop

func (worker *RefreshPatternWorker) Stop() error

Stop stops update pattern tree