adapters

May 9, 2019

Changes in this version

+ var MetricsQueue = make(chan *model.MetricSpec, 100)

+ func SendMetricToRegisteredSenders(metrics *model.MetricSpec)

+ func StartDispatcher()

+ type KafkaMetricsSender struct

+ Queue chan *model.MetricSpec

+ QuitChan chan bool

+ func (p *KafkaMetricsSender) AssignMetricsToSend(request *model.MetricSpec)

+ func (p *KafkaMetricsSender) GetMetricsSender() MetricsSenderIntf

+ func (p *KafkaMetricsSender) Start()

+ func (p *KafkaMetricsSender) Stop()

+ type MetricsSenderIntf interface

+ AssignMetricsToSend func(request *model.MetricSpec)

+ GetMetricsSender func() MetricsSenderIntf

+ Start func()

+ Stop func()

+ type PrometheusMetricsSender struct

+ Queue chan *model.MetricSpec

+ QuitChan chan bool

+ func (p *PrometheusMetricsSender) AssignMetricsToSend(request *model.MetricSpec)

+ func (p *PrometheusMetricsSender) GetMetricsSender() MetricsSenderIntf

+ func (p *PrometheusMetricsSender) Start()

+ func (p *PrometheusMetricsSender) Stop()