# Packages
No description provided by the author
# Functions
FormatSyncBinKey returns a string representation of Kademlia bin number to be used as key for SYNC stream.
No description provided by the author
No description provided by the author
NewPeer is the constructor for Peer.
No description provided by the author
NewRegistry is Streamer constructor.
No description provided by the author
NewSwarmChunkServer is SwarmChunkServer constructor.
NewSwarmSyncerClient is a contructor for provable data exchange syncer.
NewSwarmSyncerServer is constructor 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.
No description provided by the author
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
number of priority queues - Low, Mid, High, Top.
queue capacity.
Only the client side of the retrieve request is registered.(light nodes do not serve retrieve requests)once the client is registered, subscription to retrieve request stream is always sent.
Retrieval disabled.
Both client and server funcs are registered, subscribe sent automatically.
Both client and server funcs are registered, subscribe sent automatically.
Syncing disabled.
Register the client and the server but not subscribe.
No description provided by the author
# Variables
ErrMaxPeerServers will be returned if peer server limit is reached.
# Structs
No description provided by the author
Chunk delivery always uses the same message type....
No description provided by the author
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.
No description provided by the author
No description provided by the author
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.
No description provided by the author
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.
No description provided by the author
WantedHashesMsg is the protocol msg data for signaling which hashes offered in OfferedHashesMsg downstream peer actually wants sent over.
No description provided by the author
# Type aliases
defines a chunk delivery for retrieval (with accounting).
defines a chunk delivery for syncing (without accounting).
No description provided by the author
Enumerate options for syncing and retrieval.
Takeover represents a statement that downstream peer took over (stored all data) handed over.
TakeoverProofMsg is the protocol msg sent by downstream peer.