Versions in this module Expand all Collapse all v0 v0.12.0 Sep 18, 2019 Changes in this version + func AMQPConnector(a *Amqp) error + type Amqp struct + 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 interface + Handle func(io.Reader) error + 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 struct + func NewPickle(dispatcher Dispatcher) *Pickle + func (p *Pickle) Handle(c io.Reader) error + func (p *Pickle) Kind() string + type Plain struct + func NewPlain(dispatcher Dispatcher) *Plain + func (p *Plain) Handle(c io.Reader) error + 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)
Go to main page