README
¶
package listeners
This package handles the network transmission for statsd protocols and returns
packets to be processed by the dogstatsd package.
Packet
Packet is a statsd packet that might contain several statsd messages in it's
Contents field. If origin detection is supported and enabled, the Origin
field will hold the container id ready for tag resolution. If not, the field holds
an empty string.
StatsdListener
StatsdListener is the common interface, currently implemented by:
UDPListener: handles the historical UDP protocol,UDSListener: handles the host-local UDS protocol with optional origin detection, see the wiki for more info.
Origin Detection is Linux only
As our client implementations rely on Unix Credentials being added automatically by the Linux kernel, this feature is Linux only for now. If needed, server and client side could be updated and tested with other unices.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitTelemetry ¶
func InitTelemetry(buckets []float64)
InitTelemetry initialize the telemetry.Histogram buckets for the internal telemetry. This will be called once the first dogstatsd server is created since we need the configuration to be fully loaded.
Types ¶
type NamedPipeListener ¶
type NamedPipeListener struct{}
NamedPipeListener implements the StatsdListener interface for named pipe protocol.
func NewNamedPipeListener ¶
func NewNamedPipeListener(pipeName string, packetOut chan packets.Packets, sharedPacketPoolManager *packets.PoolManager, capture *replay.TrafficCapture) (*NamedPipeListener, error)
NewNamedPipeListener returns an named pipe Statsd listener
func (*NamedPipeListener) Listen ¶
func (l *NamedPipeListener) Listen()
Listen runs the intake loop. Should be called in its own goroutine
func (*NamedPipeListener) Stop ¶
func (l *NamedPipeListener) Stop()
Stop closes the connection and stops listening
type StatsdListener ¶
type StatsdListener interface {
Listen()
Stop()
}
StatsdListener opens a communication channel to get statsd packets in.
type UDPListener ¶
type UDPListener struct {
// contains filtered or unexported fields
}
UDPListener implements the StatsdListener interface for UDP protocol. It listens to a given UDP address and sends back packets ready to be processed. Origin detection is not implemented for UDP.
func NewUDPListener ¶
func NewUDPListener(packetOut chan packets.Packets, sharedPacketPoolManager *packets.PoolManager, capture *replay.TrafficCapture) (*UDPListener, error)
NewUDPListener returns an idle UDP Statsd listener
func (*UDPListener) Listen ¶
func (l *UDPListener) Listen()
Listen runs the intake loop. Should be called in its own goroutine
func (*UDPListener) Stop ¶
func (l *UDPListener) Stop()
Stop closes the UDP connection and stops listening
type UDSListener ¶
type UDSListener struct {
OriginDetection bool
// contains filtered or unexported fields
}
UDSListener implements the StatsdListener interface for Unix Domain Socket datagram protocol. It listens to a given socket path and sends back packets ready to be processed. Origin detection will be implemented for UDS.
func NewUDSListener ¶
func NewUDSListener(packetOut chan packets.Packets, sharedPacketPoolManager *packets.PoolManager, capture *replay.TrafficCapture) (*UDSListener, error)
NewUDSListener returns an idle UDS Statsd listener
func (*UDSListener) Listen ¶
func (l *UDSListener) Listen()
Listen runs the intake loop. Should be called in its own goroutine
func (*UDSListener) Stop ¶
func (l *UDSListener) Stop()
Stop closes the UDS connection and stops listening
Source Files