Versions in this module Expand all Collapse all v0 v0.0.1 Dec 29, 2017 Changes in this version + type BlackholeSender struct + Name string + func NewBlackholeSender() *BlackholeSender + func (s *BlackholeSender) GetName() string + func (s *BlackholeSender) Send(metric *carbon.Metric) + func (s *BlackholeSender) Start() + type DummySender struct + Name string + func NewDummySender(name string) *DummySender + func (s *DummySender) GetName() string + func (s *DummySender) GetReceivedMetrics() []*carbon.Metric + func (s *DummySender) Send(metric *carbon.Metric) + func (s *DummySender) Start() + func (s *DummySender) String() string + type KafkaSender struct + func (k *KafkaSender) GetName() string + func (k *KafkaSender) Send(metric *carbon.Metric) + func (k *KafkaSender) Start() + type NETSender struct + func (k *NETSender) GetName() string + func (k *NETSender) Send(metric *carbon.Metric) + func (k *NETSender) Start() + type RewritingSender struct + func NewRewritingSender(name, re, to string) *RewritingSender + func (s *RewritingSender) GetName() string + func (s *RewritingSender) Send(metric *carbon.Metric) + func (s *RewritingSender) Start() + type Sender interface + GetName func() string + Send func(metric *carbon.Metric) + Start func() + func NewKafkaSender(c common.Config, exitChan <-chan struct{}, workers, maxBatchSize int, ...) (Sender, error) + func NewTCPSender(c common.Config, exitChan <-chan struct{}, workers, maxBatchSize int, ...) (Sender, error) + type SenderInitFunc func(c common.Config, exitChan <-chan struct{}, workers, maxBatchSize int, ...) (Sender, error)
Go to main page