Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Click to show internal directories.
Click to hide internal directories.