sync

package

Go to main page

Versions in this module

v1

v1.5.0

Feb 15, 2025

Changes in this version

+ var ErrSnapshot = errors.New("snapshot error")

+ type ErrSync struct

+ BootTime uint64

+ Err error

+ Publisher enc.Name

+ func (e *ErrSync) Error() string

+ func (e *ErrSync) Unwrap() error

+ type SimplePs struct

+ func NewSimplePs[V any]() SimplePs[V]

+ func (ps *SimplePs[V]) HasSub(prefix enc.Name) bool

+ func (ps *SimplePs[V]) Publish(name enc.Name, data V)

+ func (ps *SimplePs[V]) Subs(prefix enc.Name) iter.Seq[func(V)]

+ func (ps *SimplePs[V]) Subscribe(prefix enc.Name, callback func(V)) error

+ func (ps *SimplePs[V]) Unsubscribe(prefix enc.Name)

+ type SimplePsSub struct

+ Callback func(V)

+ Prefix enc.Name

+ type Snapshot interface

+ Snapshot func() Snapshot

+ type SnapshotNodeHistory struct

+ Client ndn.Client

+ Threshold uint64

+ func (s *SnapshotNodeHistory) Snapshot() Snapshot

+ func (s *SnapshotNodeHistory) String() string

+ type SnapshotNodeLatest struct

+ Client ndn.Client

+ SnapMe func(enc.Name) (enc.Wire, error)

+ Threshold uint64

+ func (s *SnapshotNodeLatest) Snapshot() Snapshot

+ func (s *SnapshotNodeLatest) String() string

+ type SnapshotNull struct

+ func (s *SnapshotNull) Snapshot() Snapshot

type SvMap

+ func (m SvMap[V]) Iter() iter.Seq2[enc.Name, []SvMapVal[V]]

+ type SvMapVal struct

+ Boot uint64

+ Value V

+ func (*SvMapVal[V]) Cmp(a, b SvMapVal[V]) int

type SvSyncOpts

+ InitialState *spec_svs.StateVector

+ type SvsALO struct

+ func NewSvsALO(opts SvsAloOpts) *SvsALO

+ func (s *SvsALO) BootTime() uint64

+ func (s *SvsALO) DataPrefix() enc.Name

+ func (s *SvsALO) Publish(content enc.Wire) (enc.Name, *spec_svs.InstanceState, error)

+ func (s *SvsALO) SetOnError(callback func(error))

+ func (s *SvsALO) SetOnPublisher(callback func(enc.Name))

+ func (s *SvsALO) Start() error

+ func (s *SvsALO) Stop() error

+ func (s *SvsALO) String() string

+ func (s *SvsALO) SubscribePublisher(prefix enc.Name, callback func(SvsPub)) error

+ func (s *SvsALO) SyncPrefix() enc.Name

+ func (s *SvsALO) UnsubscribePublisher(prefix enc.Name)

+ type SvsAloOpts struct

+ InitialState *spec_svs.InstanceState

+ MaxPipelineSize uint64

+ Name enc.Name

+ Snapshot Snapshot

+ Svs SvSyncOpts

+ type SvsPub struct

+ BootTime uint64

+ Content enc.Wire

+ DataName enc.Name

+ IsSnapshot bool

+ Publisher enc.Name

+ SeqNum uint64

+ State *spec_svs.InstanceState

+ func (p *SvsPub) Bytes() []byte

v1.4.3

Jan 25, 2025

Changes in this version

+ type SvMap map[string][]spec_svs.SeqNoEntry

+ func NewSvMap(size int) SvMap

+ func (m SvMap) Encode() *spec_svs.StateVector

+ func (m SvMap) Get(hash string, btime uint64) spec_svs.SeqNoEntry

+ func (m SvMap) IsNewerThan(other SvMap, existOnly bool) bool

+ func (m SvMap) Set(hash string, btime uint64, seq uint64)

type SvSync

+ func (s *SvSync) GetBootTime() uint64

+ func (s *SvSync) String() string

+ type SvSyncOpts struct

+ BootTime uint64

+ Client ndn.Client

+ GroupPrefix enc.Name

+ OnUpdate func(SvSyncUpdate)

+ PeriodicTimeout time.Duration

+ SuppressionPeriod time.Duration

type SvSyncUpdate

+ Boot uint64

+ Name enc.Name

v1.4.2

Jan 3, 2025

v1.4.1

Dec 24, 2024

v1.4.0

Dec 24, 2024

Changes in this version

+ type SvSync struct

+ func NewSvSync(engine ndn.Engine, groupPrefix enc.Name, onUpdate func(SvSyncUpdate)) *SvSync

+ func (s *SvSync) GetSeqNo(nodeId enc.Name) uint64

+ func (s *SvSync) IncrSeqNo(nodeId enc.Name) uint64

+ func (s *SvSync) SetSeqNo(nodeId enc.Name, seqNo uint64) error

+ func (s *SvSync) Start() (err error)

+ func (s *SvSync) Stop()

+ type SvSyncUpdate struct

+ High uint64

+ Low uint64

+ NodeId enc.Name

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL