Versions in this module Expand all Collapse all v0 v0.1.0 Jul 14, 2026 Changes in this version + var ErrCanceledByNotifier error = errors.New("subscription canceled by the notifier") + var ErrUnsubscribed error = errors.New("subscription already unsubscribed") + type Notifier struct + func NewNotifier(options ...Options) *Notifier + func (n *Notifier) CancelAll() + func (n *Notifier) Compact() + func (n *Notifier) CurrentIndex() uint64 + func (n *Notifier) Flush() + func (n *Notifier) Stats() Stats + func (n *Notifier) Subscribe(idx uint64) Sub + func (n *Notifier) Update(idx uint64) bool + type Options struct + InitialIndex uint64 + InitialSize int + type Stats struct + ActiveIndexes int64 + ActiveSubscribers int64 + Capacity int + type Sub struct + Ch <-chan struct{} + func (s *Sub) Done() bool + func (s *Sub) Index() uint64 + func (s *Sub) IsUnsubscribed() bool + func (s *Sub) NotifierIndex() uint64 + func (s *Sub) Unsubscribe() + func (s *Sub) Wait(ctx context.Context) error
Go to main page