Versions in this module Expand all Collapse all v0 v0.1.0 Jan 28, 2021 Changes in this version + var ErrBadSequence = errors.New("bad sequence") + var ErrNoMoreRoom = errors.New("queue full") + type Manager struct + MaxSize int + func NewManager() *Manager + func (m *Manager) Addresses() []string + func (m *Manager) Push(address string, sequence uint64) <-chan error + func (m *Manager) Size() int + func (m *Manager) String() string + func (m *Manager) Update(updates map[string]uint64) + type Queue struct + func NewQueue() *Queue + func (q *Queue) Push(sequence uint64) <-chan error + func (q *Queue) Size() int + func (q *Queue) Update(sequence uint64)