Versions in this module Expand all Collapse all v0 v0.11.2 Feb 22, 2026 v0.11.1 Feb 21, 2026 v0.11.0 Feb 11, 2026 Changes in this version + var ErrOffsetNotifyClosed = errors.New("offset notify already closed") + type Offset struct + func NewOffset(nextOffset int64) *Offset + func (w *Offset) Close() error + func (w *Offset) Set(nextOffset int64) + func (w *Offset) Wait(ctx context.Context, offset int64) error
Go to main page