types

Mar 20, 2019

Changes in this version

+ type WritePool interface

+ Get func(io.Reader) *bufio.Reader

+ Put func(*bufio.Reader)

+ func NewWritePool(size, preAlloc, grow, shrink int) (WritePool, error)

Oct 31, 2018

Changes in this version

+ var ErrClosed = fmt.Errorf("pool: closed")

+ var ErrScheduleTimeout = fmt.Errorf("pool: schedule error: timed out")

+ type Pool interface

+ Close func() error

+ Schedule func(task func()) error

+ ScheduleTimeout func(timeout time.Duration, task func()) error

+ func NewPool(size, queue, spawn int) Pool

Oct 23, 2018

Changes in this version

+ type Queue struct

+ func NewQueue() *Queue

+ func (q *Queue) Add(elem interface{})

+ func (q *Queue) Get(i int) interface{}

+ func (q *Queue) Length() int

+ func (q *Queue) Peek() interface{}

+ func (q *Queue) Remove() interface{}

Sep 21, 2017

Changes in this version

+ const DefaultAckTimeout

+ const DefaultAuthenticator

+ const DefaultConnectTimeout

+ const DefaultKeepAlive

+ const DefaultMaxPacketSize

+ const DefaultReceiveMax

+ const DefaultSessionsProvider

+ const DefaultTimeoutRetries

+ const DefaultTopicsProvider

+ const MinKeepAlive

+ type LogInterface struct

+ Dev *zap.Logger

+ Prod *zap.Logger

+ type Once struct

+ func (o *Once) Do(f func()) bool

+ type OnceWait struct

+ func (o *OnceWait) Do(f func()) bool

+ type RetainObject interface

+ Topic func() string

+ type TopicMessenger interface

+ Publish func(interface{}) error

+ Retain func(RetainObject) error