messages

Jul 7, 2019

Changes in this version

type Queue

+ func (q *Queue) Consume(f func(*packet.Publish))

Jun 4, 2019

Changes in this version

+ var ErrQueueEmpty = errors.New("queue empty")

+ var ErrQueueFull = errors.New("queue is full")

+ type Queue struct

+ func NewQueue() *Queue

+ func (q *Queue) Close() error

+ func (q *Queue) Pop() (*packet.Publish, error)

+ func (q *Queue) Put(timestamp time.Time, p *packet.Publish) error