pushsync

Aug 4, 2023

Changes in this version

+ type Storer interface

+ IsWithinStorageRadius func(swarm.Address) bool

+ ReservePutter func() storage.Putter

+ StorageRadius func() uint8

May 1, 2023

Changes in this version

type PushSync

+ func (s *PushSync) Close() error

Sep 12, 2022

Changes in this version

type Receipt

+ Nonce []byte

Oct 7, 2021

Changes in this version

+ var ErrOutOfDepthStoring = errors.New("storing outside of the neighborhood")

Jun 21, 2021

Changes in this version

+ var ErrWarmup = errors.New("node warmup time not complete")

type Receipt

+ BlockHash []byte

May 20, 2021

Changes in this version

+ var ErrNoPush = errors.New("could not push chunk")

+ var ErrOutOfDepthReplication = errors.New("replication outside of the neighborhood")

type Receipt

+ Signature []byte

Jun 29, 2020

Changes in this version

+ type Options struct

+ ClosestPeerer topology.ClosestPeerer

+ Logger logging.Logger

+ Storer storage.Putter

+ Streamer p2p.Streamer

+ type PushSync struct

+ func New(o Options) *PushSync

+ func (ps *PushSync) PushChunkToClosest(ctx context.Context, ch swarm.Chunk) (*Receipt, error)

+ func (s *PushSync) Metrics() []prometheus.Collector

+ func (s *PushSync) Protocol() p2p.ProtocolSpec

+ type PushSyncer interface

+ PushChunkToClosest func(ctx context.Context, ch swarm.Chunk) (*Receipt, error)

+ type Receipt struct

+ Address swarm.Address