tcp

Documentation

Index

• type FramingOptions
  • func NewFramingOptions() *FramingOptions
• type Options
  • func NewOptions() *Options
• type TCP
  • func (rcv *TCP) Addr() net.Addr
  • func (rcv *TCP) HandleConnection(conn net.Conn)
  • func (rcv *TCP) InitPrometheus(reg prometheus.Registerer)
  • func (rcv *TCP) Listen(addr *net.TCPAddr) error
  • func (rcv *TCP) Stat(send helper.StatCallback)

Types

type FramingOptions

type FramingOptions struct {
	Listen         string `toml:"listen"`
	MaxMessageSize uint32 `toml:"max-message-size"`
	Enabled        bool   `toml:"enabled"`
	BufferSize     int    `toml:"buffer-size"`
}

func NewFramingOptions

func NewFramingOptions() *FramingOptions

type Options

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

func NewOptions

func NewOptions() *Options

type TCP

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

TCP receive metrics from TCP connections

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

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

func (*TCP) Listen

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

Listen bind port. Receive messages and send to out channel

func (*TCP) Stat

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