matchedmetrics

Documentation

Index

• type MetricsMatcher
  • func NewMetricsMatcher(metrics *graphite.FilterMetrics, logger moira.Logger, database moira.Database, ...) *MetricsMatcher
  • func (matcher *MetricsMatcher) Start(matchedMetricsChan chan *moira.MatchedMetric)
  • func (matcher *MetricsMatcher) Wait()

Types

type MetricsMatcher

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

MetricsMatcher make buffer of metrics and save it

func NewMetricsMatcher

func NewMetricsMatcher(metrics *graphite.FilterMetrics, logger moira.Logger, database moira.Database, cacheStorage *filter.Storage, cacheCapacity int) *MetricsMatcher

NewMetricsMatcher creates new MetricsMatcher

func (*MetricsMatcher) Start

func (matcher *MetricsMatcher) Start(matchedMetricsChan chan *moira.MatchedMetric)

Start process matched metrics from channel and save it in cache storage

func (*MetricsMatcher) Wait

func (matcher *MetricsMatcher) Wait()

Wait waits for metric matcher instance will stop