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