Versions in this module Expand all Collapse all v0 v0.2.3 Jun 20, 2021 Changes in this version + type Option interface + func WithAutoReply() Option + func WithCursors(v []uint64) Option + func WithLateSyncReply(r ...SyncReply) Option + func WithLiveSyncBlock() Option + func WithLiveSyncReplies(r ...uint64) Option + type PullSyncMock struct + func NewPullSync(opts ...Option) *PullSyncMock + func (p *PullSyncMock) CancelRuid(ctx context.Context, peer swarm.Address, ruid uint32) error + func (p *PullSyncMock) Close() error + func (p *PullSyncMock) CursorsCalls(peer swarm.Address) bool + func (p *PullSyncMock) GetCursors(_ context.Context, peer swarm.Address) ([]uint64, error) + func (p *PullSyncMock) LiveSyncCalls(peer swarm.Address) (res []SyncCall) + func (p *PullSyncMock) SyncCalls(peer swarm.Address) (res []SyncCall) + func (p *PullSyncMock) SyncInterval(ctx context.Context, peer swarm.Address, bin uint8, from, to uint64) (topmost uint64, ruid uint32, err error) + func (p *PullSyncMock) TriggerChange() + type SyncCall struct + Bin uint8 + From uint64 + Live bool + Peer swarm.Address + To uint64 + type SyncReply struct + func NewReply(bin uint8, from, top uint64, block bool) SyncReply
Go to main page