FormatSyncBinKey returns a string representation of Kademlia bin number to be used as key for SYNC stream.

NewPeer is the constructor for Peer.

NewRegistry is Streamer constructor.

NewSwarmChunkServer is SwarmChunkServer constructor.

NewSwarmSyncerClient is a contructor for provable data exchange syncer.

NewSwarmSyncerServer is contructor for SwarmSyncerServer.

ParseSyncBinKey parses the string representation and returns the Kademlia bin number.

RegisterSwarmSyncerClient registers the client constructor function for to handle incoming sync streams.

BatchSize = 2.

number of queues.

queue capacity.

Spec is the spec of the streamer protocol.

Handover represents a statement that the upstream peer hands over the stream section.

HandoverProof represents a signed statement that the upstream peer handed over the stream section.

OfferedHashesMsg is the protocol msg for offering to hand over a stream section.

Peer is the Peer extension for the streaming protocol.

Registry registry for outgoing and incoming streamer constructors.

RegistryOptions holds optional values for NewRegistry constructor.

RequestSubscriptionMsg is the protocol msg for a node to request subscription to a specific stream.

RetrieveRequestMsg is the protocol msg for chunk retrieve requests.

Stream defines a unique stream identifier.

SubcribeMsg is the protocol msg for requesting a stream(section).

SwarmChunkServer implements Server.

SwarmSyncerClient.

SwarmSyncerServer implements an Server for history syncing on bins offered streams: * live request delivery with or without checkback * (live/non-live historical) chunk syncing per proximity bin.

TakeoverProof represents a signed statement that the downstream peer took over the stream section.

WantedHashesMsg is the protocol msg data for signaling which hashes offered in OfferedHashesMsg downstream peer actually wants sent over.

Client interface for incoming peer Streamer.

Server interface for outgoing peer Streamer.

Takeover represents a statement that downstream peer took over (stored all data) handed over.

TakeoverProofMsg is the protocol msg sent by downstream peer.