Versions in this module Expand all Collapse all v0 v0.0.3 Apr 21, 2025 v0.0.2 Apr 21, 2025 Changes in this version + const DefaultMaxPage + const MaxCursor + var ErrUnsolicitedChunk = errors.New("peer sent unsolicited chunk") + type Interface interface + GetCursors func(ctx context.Context, peer swarm.Address) ([]uint64, uint64, error) + Sync func(ctx context.Context, peer swarm.Address, bin uint8, start uint64) (topmost uint64, count int, err error) + type Syncer struct + func New(streamer p2p.Streamer, store storer.Reserve, unwrap func(swarm.Chunk), ...) *Syncer + func (s *Syncer) Close() error + func (s *Syncer) GetCursors(ctx context.Context, peer swarm.Address) (retr []uint64, epoch uint64, err error) + func (s *Syncer) Metrics() []prometheus.Collector + func (s *Syncer) Protocol() p2p.ProtocolSpec + func (s *Syncer) Sync(ctx context.Context, peer swarm.Address, bin uint8, start uint64) (uint64, int, error)
Go to main page