listeners

Documentation

Index

• type Batcher
• type GRPCListener
  • func NewGRPCListener(router *grpcmanager.Router, sinkmanager *sinkmanager.SinkManager, ...) (*GRPCListener, error)
  • func (g *GRPCListener) Start()
• type TCPListener
  • func NewTCPListener(metricProto, address string, tlsListenerConfig *config.TLSListenerConfig, ...) (*TCPListener, error)
  • func (t *TCPListener) Address() string
  • func (t *TCPListener) Start()
  • func (t *TCPListener) Stop()
• type UDPListener
  • func NewUDPListener(host string, batcher Batcher, metricProto string) (*UDPListener, <-chan []byte)
  • func (l *UDPListener) Address() string
  • func (l *UDPListener) Start()
  • func (l *UDPListener) Stop()

Types

type Batcher

type Batcher interface {
	BatchCounter(name string) metricbatcher.BatchCounterChainer
	BatchIncrementCounter(name string)
	BatchAddCounter(name string, delta uint64)
}

type GRPCListener

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

func NewGRPCListener

func NewGRPCListener(
	router *grpcmanager.Router,
	sinkmanager *sinkmanager.SinkManager,
	conf config.GRPC,
	envelopeBuffer *diodes.ManyToOneEnvelope,
	batcher *metricbatcher.MetricBatcher,
) (*GRPCListener, error)

func (*GRPCListener) Start

func (g *GRPCListener) Start()

type TCPListener

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

func NewTCPListener

func NewTCPListener(
	metricProto, address string,
	tlsListenerConfig *config.TLSListenerConfig,
	envelopesBuffer *diodes.ManyToOneEnvelope,
	batcher Batcher,
	deadline time.Duration,
) (*TCPListener, error)

func (*TCPListener) Address

func (t *TCPListener) Address() string

func (*TCPListener) Start

func (t *TCPListener) Start()

func (*TCPListener) Stop

func (t *TCPListener) Stop()

type UDPListener

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

func NewUDPListener

func NewUDPListener(host string, batcher Batcher, metricProto string) (*UDPListener, <-chan []byte)

func (*UDPListener) Address

func (l *UDPListener) Address() string

func (*UDPListener) Start

func (l *UDPListener) Start()

func (*UDPListener) Stop

func (l *UDPListener) Stop()