udp

Documentation

Index

• type Options
  • func NewOptions() *Options
• type UDP
  • func (rcv *UDP) Addr() net.Addr
  • func (rcv *UDP) InitPrometheus(reg prometheus.Registerer)
  • func (rcv *UDP) Listen(addr *net.UDPAddr) error
  • func (rcv *UDP) Stat(send helper.StatCallback)

Types

type Options

type Options struct {
	Listen     string `toml:"listen"`
	Enabled    bool   `toml:"enabled"`
	BufferSize int    `toml:"buffer-size"`
}

func NewOptions

func NewOptions() *Options

type UDP

type UDP struct {
	helper.Stoppable
	// contains filtered or unexported fields
}

UDP receive metrics from UDP socket

func (*UDP) Addr

func (rcv *UDP) Addr() net.Addr

Addr returns binded socket address. For bind port 0 in tests

func (*UDP) InitPrometheus

func (rcv *UDP) InitPrometheus(reg prometheus.Registerer)

InitPrometheus is a stub for the receiver prom metrics. Required to satisfy Receiver interface.

func (*UDP) Listen

func (rcv *UDP) Listen(addr *net.UDPAddr) error

Listen bind port. Receive messages and send to out channel

func (*UDP) Stat

func (rcv *UDP) Stat(send helper.StatCallback)