Versions in this module Expand all Collapse all v0 v0.2.6 Mar 20, 2019 Changes in this version + const DefaultAckTimeout + const DefaultAuthenticator + const DefaultConnectTimeout + const DefaultKeepAlive + const DefaultMaxPacketSize + const DefaultReceiveMax + const DefaultSessionsProvider + const DefaultTimeoutRetries + const DefaultTopicsProvider + const MinKeepAlive + var ErrClosed = fmt.Errorf("pool: closed") + var ErrScheduleTimeout = fmt.Errorf("pool: schedule error: timed out") + 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 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 + 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{} + type RetainObject interface + Topic func() string + type TopicMessenger interface + Publish func(interface{}) error + Retain func(RetainObject) error + type WritePool interface + Get func(io.Reader) *bufio.Reader + Put func(*bufio.Reader) + func NewWritePool(size, preAlloc, grow, shrink int) (WritePool, error)