transport

Documentation

Index

• type BlackholeSender
  • func NewBlackholeSender() *BlackholeSender
  • func (s *BlackholeSender) GetName() string
  • func (s *BlackholeSender) Send(metric *carbon.Metric)
  • func (s *BlackholeSender) Start()
• type DummySender
  • 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
  • func (k *KafkaSender) GetName() string
  • func (k *KafkaSender) Send(metric *carbon.Metric)
  • func (k *KafkaSender) Start()
• type NETSender
  • func (k *NETSender) GetName() string
  • func (k *NETSender) Send(metric *carbon.Metric)
  • func (k *NETSender) Start()
• type RewritingSender
  • 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
  • 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

Types

type BlackholeSender

type BlackholeSender struct {
	Name string
}

func NewBlackholeSender

func NewBlackholeSender() *BlackholeSender

func (*BlackholeSender) GetName

func (s *BlackholeSender) GetName() string

func (*BlackholeSender) Send

func (s *BlackholeSender) Send(metric *carbon.Metric)

func (*BlackholeSender) Start

func (s *BlackholeSender) Start()

type DummySender

type DummySender struct {
	Name string
	// contains filtered or unexported fields
}

DummySender should only be used for testing purposes

func NewDummySender

func NewDummySender(name string) *DummySender

func (*DummySender) GetName

func (s *DummySender) GetName() string

func (*DummySender) GetReceivedMetrics

func (s *DummySender) GetReceivedMetrics() []*carbon.Metric

func (*DummySender) Send

func (s *DummySender) Send(metric *carbon.Metric)

func (*DummySender) Start

func (s *DummySender) Start()

Start should start the dummy sender, but actually it doesn't do anything

func (*DummySender) String

func (s *DummySender) String() string

type KafkaSender

type KafkaSender struct {
	common.Config
	// contains filtered or unexported fields
}

func (*KafkaSender) GetName

func (k *KafkaSender) GetName() string

func (*KafkaSender) Send

func (k *KafkaSender) Send(metric *carbon.Metric)

func (*KafkaSender) Start

func (k *KafkaSender) Start()

type NETSender

type NETSender struct {
	common.Config
	// contains filtered or unexported fields
}

func (*NETSender) GetName

func (k *NETSender) GetName() string

func (*NETSender) Send

func (k *NETSender) Send(metric *carbon.Metric)

func (*NETSender) Start

func (k *NETSender) Start()

type RewritingSender

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

func NewRewritingSender

func NewRewritingSender(name, re, to string) *RewritingSender

func (*RewritingSender) GetName

func (s *RewritingSender) GetName() string

func (*RewritingSender) Send

func (s *RewritingSender) Send(metric *carbon.Metric)

func (*RewritingSender) Start

func (s *RewritingSender) Start()

type Sender

type Sender interface {
	Start()
	Send(metric *carbon.Metric)
	GetName() string
}

func NewKafkaSender

func NewKafkaSender(c common.Config, exitChan <-chan struct{}, workers, maxBatchSize int, sendInterval time.Duration) (Sender, error)

func NewTCPSender

func NewTCPSender(c common.Config, exitChan <-chan struct{}, workers, maxBatchSize int, sendInterval time.Duration) (Sender, error)

type SenderInitFunc

type SenderInitFunc func(c common.Config, exitChan <-chan struct{}, workers, maxBatchSize int, sendInterval time.Duration) (Sender, error)