receiver

Documentation

Index

• type TCP
  • func NewPickle(out chan *points.Points) *TCP
  • func NewTCP(out chan *points.Points) *TCP
  • func (rcv *TCP) Addr() net.Addr
  • func (rcv *TCP) HandleConnection(conn net.Conn)
  • func (rcv *TCP) Listen(addr *net.TCPAddr) error
  • func (rcv *TCP) SetMaxPickleMessageSize(newSize uint32)
  • func (rcv *TCP) Stat(send func(metric string, value float64))
• type UDP
  • func NewUDP(out chan *points.Points) *UDP
  • func (rcv *UDP) Addr() net.Addr
  • func (rcv *UDP) Listen(addr *net.UDPAddr) error
  • func (rcv *UDP) SetLogIncomplete(value bool)
  • func (rcv *UDP) Stat(send func(metric string, value float64))

Types

type TCP

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

TCP receive metrics from TCP connections

func NewPickle

func NewPickle(out chan *points.Points) *TCP

NewPickle create new instance of TCP with pickle listener enabled

func NewTCP

func NewTCP(out chan *points.Points) *TCP

NewTCP create new instance of TCP

func (*TCP) Addr

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

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

func (*TCP) HandleConnection

func (rcv *TCP) HandleConnection(conn net.Conn)

func (*TCP) Listen

func (rcv *TCP) Listen(addr *net.TCPAddr) error

Listen bind port. Receive messages and send to out channel

func (*TCP) SetMaxPickleMessageSize

func (rcv *TCP) SetMaxPickleMessageSize(newSize uint32)

SetMaxPickleMessageSize sets maxPickleMessageSize (in bytes)

func (*TCP) Stat

func (rcv *TCP) Stat(send func(metric string, value float64))

type UDP

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

UDP receive metrics from UDP socket

func NewUDP

func NewUDP(out chan *points.Points) *UDP

NewUDP create new instance of UDP

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) SetLogIncomplete

func (rcv *UDP) SetLogIncomplete(value bool)

SetLogIncomplete enable or disable incomplete messages logging

func (*UDP) Stat

func (rcv *UDP) Stat(send func(metric string, value float64))