synchub

Nov 8, 2023

Changes in this version

type Sync

+ DoneSub func(subSyncID interface{}) bool

type SyncHub

+ func (sh *SyncHub) DoneSub(syncID interface{}, subSyncID interface{}) bool

type SyncOption

+ func WithSub(subSyncIDs ...interface{}) SyncOption

Jul 5, 2023

Changes in this version

type SyncHub

+ func (sh *SyncHub) Add(syncID interface{}, opts ...SyncOption) Sync

type SyncOption

+ func WithContext(ctx context.Context) SyncOption

Jun 7, 2023

Changes in this version

+ var ErrSyncCanceled = errors.New("sync canceled")

+ var ErrSyncHubClosed = errors.New("synchub closed")

+ var ErrSyncHubForceClosed = errors.New("force closed")

+ var ErrSyncIDResynced = errors.New("id resynced")

+ var ErrSyncTimeout = errors.New("timeout")

+ var ErrTimerNotWorking = errors.New("timer not working")

+ type Event struct

+ Ack interface{}

+ Data interface{}

+ Error error

+ SyncID interface{}

+ type Sync interface

+ Ack func(ack interface{}) bool

+ C func() <-chan *Event

+ Cancel func(notify bool) bool

+ Done func() bool

+ Error func(err error) bool

+ type SyncHub struct

+ func NewSyncHub(opts ...SyncHubOption) *SyncHub

+ func (sh *SyncHub) Ack(syncID interface{}, ack interface{}) bool

+ func (sh *SyncHub) Cancel(syncID interface{}, notify bool) bool

+ func (sh *SyncHub) Close()

+ func (sh *SyncHub) Done(syncID interface{}) bool

+ func (sh *SyncHub) Error(syncID interface{}, err error) bool

+ func (sh *SyncHub) New(syncID interface{}, opts ...SyncOption) Sync

+ type SyncHubOption func(*SyncHub)

+ func OptionTimer(tmr timer.Timer) SyncHubOption

+ type SyncOption func(*synchronize)

+ func WithCallback(cb func(*Event)) SyncOption

+ func WithData(data interface{}) SyncOption

+ func WithEventChan(ch chan *Event) SyncOption

+ func WithTimeout(d time.Duration) SyncOption