inflight

Nov 10, 2018

Changes in this version

+ var ErrMessageNotFound = fmt.Errorf("message not found")

+ var ErrNotFound = fmt.Errorf("queue not found")

+ type Message struct

+ ID int32

+ Publish *packet.Publish

+ type MessageList []*Message

+ func (m MessageList) Apply(f func(*Message))

+ func (m MessageList) ApplyE(f func(*Message) error) (err error)

+ func (m MessageList) Filter(f func(*Message) bool) MessageList

+ func (m MessageList) Find(f func(*Message) bool) *Message

+ type Queue struct

+ func New(depth int) *Queue

+ func (q *Queue) Acknowledge(messageID int32) error

+ func (q *Queue) Capacity() int

+ func (q *Queue) Close() error

+ func (q *Queue) Empty()

+ func (q *Queue) ExpireInflight()

+ func (q *Queue) InflightCount() int

+ func (q *Queue) Insert(p *packet.Publish) error

+ func (q *Queue) MessageCount() int

+ func (q *Queue) Next() *Message