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) Listen(addr *net.TCPAddr) error
  • func (rcv *TCP) SetGraphPrefix(prefix string)
  • func (rcv *TCP) Stat(metric string, value float64)
  • func (rcv *TCP) Stop()
• 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) SetGraphPrefix(prefix string)
  • func (rcv *UDP) SetLogIncomplete(value bool)
  • func (rcv *UDP) Stat(metric string, value float64)
  • func (rcv *UDP) Stop()

Types

type TCP

type TCP struct {
	// 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) Listen

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

Listen bind port. Receive messages and send to out channel

func (*TCP) SetGraphPrefix

func (rcv *TCP) SetGraphPrefix(prefix string)

SetGraphPrefix for internal cache metrics

func (*TCP) Stat

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

Stat sends internal statistics to cache

func (*TCP) Stop

func (rcv *TCP) Stop()

Stop all listeners

type UDP

type UDP struct {
	// 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) SetGraphPrefix

func (rcv *UDP) SetGraphPrefix(prefix string)

SetGraphPrefix for internal cache metrics

func (*UDP) SetLogIncomplete

func (rcv *UDP) SetLogIncomplete(value bool)

SetLogIncomplete enable or disable incomplete messages logging

func (*UDP) Stat

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

Stat sends internal statistics to cache

func (*UDP) Stop

func (rcv *UDP) Stop()

Stop all listeners