Versions in this module Expand all Collapse all v0 v0.3.1 Feb 2, 2017 v0.3.0 Dec 30, 2016 v0.2.1 Dec 14, 2016 Changes in this version + var BufferPool = sync.Pool + func HasDoubleDot(p []byte) bool + func PlainParseBuffer(exit chan struct{}, b *Buffer, out chan *RowBinary.WriteBuffer, ...) + func PlainParseLine(p []byte) ([]byte, float64, uint32, error) + func PlainParser(exit chan struct{}, in chan *Buffer, out chan *RowBinary.WriteBuffer, ...) + func RemoveDoubleDot(p []byte) []byte + type Buffer struct + Body [262144]byte + Time uint32 + Used int + func GetBuffer() *Buffer + func (b *Buffer) Release() + func (b *Buffer) Reset() *Buffer + func (b *Buffer) Write(p []byte) + type Option func(Receiver) error + func Logger(logger zap.Logger) Option + func ParseThreads(threads int) Option + func WriteChan(ch chan *RowBinary.WriteBuffer) Option + type Receiver interface + Stat func(func(metric string, value float64)) + Stop func() + func New(dsn string, opts ...Option) (Receiver, error) + type TCP struct + func (rcv *TCP) Addr() net.Addr + func (rcv *TCP) HandleConnection(conn net.Conn) + func (rcv *TCP) Listen(addr *net.TCPAddr) error + func (rcv *TCP) Stat(send func(metric string, value float64)) + type UDP struct + func (rcv *UDP) Addr() net.Addr + func (rcv *UDP) Listen(addr *net.UDPAddr) error + func (rcv *UDP) Stat(send func(metric string, value float64))
Go to main page