udp

Documentation

Index

• type Options
  • func NewOptions() *Options
• type UDP
  • func (rcv *UDP) Addr() net.Addr
  • 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"`
	LogIncomplete bool   `toml:"log-incomplete"`
	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) 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)