Versions in this module Expand all Collapse all v0 v0.5.2 Jan 31, 2023 Changes in this version + type Options struct + ClientID string + DefaultNotifier queue.Notifier + InflightExpiry time.Duration + MaxQueuedMsg int + type Queue struct + func New(opts Options) (*Queue, error) + func (*Queue) Clean() error + func (q *Queue) Add(elem *queue.Elem) (err error) + func (q *Queue) Close() error + func (q *Queue) Init(opts *queue.InitOptions) error + func (q *Queue) Read(pids []packets.PacketID) (rs []*queue.Elem, err error) + func (q *Queue) ReadInflight(maxSize uint) (rs []*queue.Elem, err error) + func (q *Queue) Remove(pid packets.PacketID) error + func (q *Queue) Replace(elem *queue.Elem) (replaced bool, err error)
Go to main page