Versions in this module Expand all Collapse all v0 v0.12.1 Apr 26, 2026 v0.12.0 Apr 25, 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