Module kitsune_p2p::gossip::sharded_gossip

The main (and only) Sharded gossiping strategy

Structs

• Accept
  Accept an incoming round of gossip from a remote node
• Agents
  Send Agent Info Bloom
• AlreadyInProgress
  You have sent a stale initiate to a node that already has an active round with you.
• BandwidthThrottle
  Manages incoming and outgoing bandwidth by providing methods which asynchronously wait for enough bandwidth to become available before processing a chunk of bytes
• BandwidthThrottles
  Set of bandwidth throttles for all gossip loops.
• Busy
  The node currently is gossiping with too many other nodes and is too busy to accept your initiate. Please try again later.
• Error
  The node you are gossiping with has hit an error condition and failed to respond to a request.
• InOut
  Incoming and outgoing throughput
• Initiate
  Initiate a round of gossip with a remote node
• KitsuneDiagnostics
  Data and handlers for diagnostic info, to be used by the host.
• MissingAgents
  Any agents that were missing from the remote bloom.
• MissingOpHashes
  Any ops that were missing from the remote bloom.
• NoAgents
  The node you are trying to gossip with has no agents anymore.
• OpBatchReceived
  I have received a complete batch of missing ops and I am ready to receive the next batch.
• OpBloom
  Send Op Bloom filter
• OpRegions
  Send Op region hashes
• RoundState
  The state representing a single active ongoing “round” of gossip with a remote node
• ShardedGossip
  The entry point for the sharded gossip strategy.
• ShardedGossipLocal
  The parts of sharded gossip which are concerned only with the gossiping node:
• ShardedGossipLocalState
  The internal mutable state for ShardedGossipLocal
• ShardedGossipQueues
  The incoming and outgoing queues for ShardedGossip

Enums

• EncodedTimedBloomFilter
  An encoded timed bloom filter of missing op hashes.
• GossipType
  Gossip has two distinct variants which share a lot of similarities but are fundamentally different and serve different purposes
• MissingOpsStatus
  The possible states when receiving missing ops. Note this is not sent over the wire and is instead converted to a u8 to save bandwidth.
• ShardedGossipWire
  ShardedGossip Wire Protocol Codec

Functions

• historical_factory
  Create a historical GossipModuleFactory
• recent_factory
  Create a recent GossipModuleFactory

Type Aliases

• NodeId
  A peer (from the perspective of any other node) is uniquely identified by its Cert
• RegionDiffs
  Our region diff and their region diff