input

Nov 9, 2018

Changes in this version

+ func AMQPConnector(a *Amqp) error

type Amqp

+ func NewAMQP(config cfg.Config, dispatcher Dispatcher, connect amqpConnector) *Amqp

+ func (a *Amqp) Name() string

+ func (a *Amqp) Start() error

+ func (a *Amqp) Stop() bool

+ type Closable interface

+ Close func() error

+ type Dispatcher interface

+ Dispatch func(buf []byte)

+ IncNumInvalid func()

type Handler

+ Kind func() string

+ type Listener struct

+ HandleConn func(l *Listener, c net.Conn)

+ HandleData func(l *Listener, data []byte, src net.Addr)

+ Handler Handler

+ func NewListener(addr string, readTimeout time.Duration, handler Handler) *Listener

+ func (l *Listener) Name() string

+ func (l *Listener) Start() error

+ func (l *Listener) Stop() bool

type Pickle

+ func (p *Pickle) Kind() string

type Plain

+ func (p *Plain) Kind() string

+ type Plugin interface

+ Name func() string

+ Start func() error

+ Stop func() bool

+ type TimeoutConn struct

+ func NewTimeoutConn(conn net.Conn, readTimeout time.Duration) TimeoutConn

+ func (t TimeoutConn) Read(p []byte) (n int, err error)

Feb 16, 2017

Changes in this version

+ func InitMetrics()

+ func NewPickle(config cfg.Config, addr string, tbl *table.Table, bad *badmetrics.BadMetrics) (net.Listener, error)

+ func NewPlain(config cfg.Config, addr string, tbl *table.Table, ...) (net.Listener, error)

+ func SetLogger(l *logging.Logger)

+ func StartAMQP(config cfg.Config, tbl *table.Table, bad *badmetrics.BadMetrics)

+ type Amqp struct

+ type Handler interface

+ Handle func(net.Conn)

+ type Pickle struct

+ func (p *Pickle) Handle(c net.Conn)

+ type Plain struct

+ func (p *Plain) Handle(c net.Conn)