Versions in this module Expand all Collapse all v4 v4.99.0 Oct 19, 2026 Changes in this version + var ErrSyncAborted = errors.New("sync aborted before the checkpoint could be sent") + func Deliver(ctx context.Context, res chan<- message.SyncMessage, msg message.SyncMessage) error + func Drop(msg message.SyncMessage) + func WithScope(ctx context.Context, scope Scope) context.Context + type Barrier struct + func (*Barrier) GetTable() *schema.Table + func (*Barrier) IsSyncMessage() bool + type Collapsing interface + Collapsed func() Scope + type Delivery struct + func NewHeld(holder Scope) *Delivery + func Schedule(ctx context.Context, res chan<- message.SyncMessage, scope Scope, ...) (*Delivery, error) + func (s *Delivery) Abort() + func (s *Delivery) Aborted() bool + func (s *Delivery) Delivered() bool + func (s *Delivery) Finish(ctx context.Context, res chan<- message.SyncMessage) error + func (s *Delivery) MergeInto(into *Delivery) + func (s *Delivery) MergedInto(into *Delivery) bool + func (s *Delivery) NotifyAbort(flag *atomic.Bool) + type Ordering interface + SendsAfter func(delivery *Delivery) bool + type Scope interface + Checkpoint func(ctx context.Context, msg message.SyncMessage) error + func Collapse(scope Scope) Scope + func FromContext(ctx context.Context) Scope + func Join(scopes ...Scope) Scope + type Tracked struct + Delivery *Delivery + Message message.SyncMessage + func (*Tracked) GetTable() *schema.Table + func (*Tracked) IsSyncMessage() bool
Go to main page