Enum holochain::prelude::kitsune_p2p::gossip::sharded_gossip::ShardedGossipWire

pub enum ShardedGossipWire {
    Initiate(Initiate),
    Accept(Accept),
    Agents(Agents),
    MissingAgents(MissingAgents),
    OpBloom(OpBloom),
    OpRegions(OpRegions),
    MissingOpHashes(MissingOpHashes),
    OpBatchReceived(OpBatchReceived),
    Error(Error),
    Busy(Busy),
    NoAgents(NoAgents),
    AlreadyInProgress(AlreadyInProgress),
}

ShardedGossip Wire Protocol Codec

Variants

Initiate(Initiate)

Initiate a round of gossip with a remote node

Accept(Accept)

Accept an incoming round of gossip from a remote node

Agents(Agents)

Send Agent Info Bloom

MissingAgents(MissingAgents)

Any agents that were missing from the remote bloom.

OpBloom(OpBloom)

Send Op Bloom filter

OpRegions(OpRegions)

Send Op region hashes

MissingOpHashes(MissingOpHashes)

Any ops that were missing from the remote bloom.

OpBatchReceived(OpBatchReceived)

I have received a complete batch of missing ops and I am ready to receive the next batch.

Error(Error)

The node you are gossiping with has hit an error condition and failed to respond to a request.

Busy(Busy)

The node currently is gossiping with too many other nodes and is too busy to accept your initiate. Please try again later.

NoAgents(NoAgents)

The node you are trying to gossip with has no agents anymore.

AlreadyInProgress(AlreadyInProgress)

You have sent a stale initiate to a node that already has an active round with you.

Implementations

impl ShardedGossipWire

pub fn initiate( intervals: Vec<DhtArcRange<DhtLocation>, Global>, id: u32, agent_list: Vec<AgentInfoSigned, Global> ) -> ShardedGossipWire

Variant constructor helper function.

pub fn accept( intervals: Vec<DhtArcRange<DhtLocation>, Global>, agent_list: Vec<AgentInfoSigned, Global> ) -> ShardedGossipWire

Variant constructor helper function.

pub fn agents(filter: PoolBuf) -> ShardedGossipWire

Variant constructor helper function.

pub fn missing_agents( agents: Vec<Arc<AgentInfoSigned>, Global> ) -> ShardedGossipWire

Variant constructor helper function.

pub fn op_bloom( missing_hashes: EncodedTimedBloomFilter, finished: bool ) -> ShardedGossipWire

Variant constructor helper function.

pub fn op_regions(region_set: RegionSetLtcs<RegionData>) -> ShardedGossipWire

Variant constructor helper function.

pub fn missing_op_hashes( ops: Vec<RoughSized<Arc<KitsuneOpHash>>, Global>, finished: u8 ) -> ShardedGossipWire

Variant constructor helper function.

pub fn op_batch_received() -> ShardedGossipWire

Variant constructor helper function.

pub fn error(message: String) -> ShardedGossipWire

Variant constructor helper function.

pub fn busy() -> ShardedGossipWire

Variant constructor helper function.

pub fn no_agents() -> ShardedGossipWire

Variant constructor helper function.

pub fn already_in_progress() -> ShardedGossipWire

Variant constructor helper function.

Trait Implementations

impl Clone for ShardedGossipWire

fn clone(&self) -> ShardedGossipWire

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Codec for ShardedGossipWire

fn variant_type(&self) -> &'static str

Variant identifier (for debugging or as a cheap discriminant).

fn encode<W>(&self, w: &mut W) -> Result<(), Error>where W: Write,

Encode this item to given writer. You may wish to first wrap your writer in a BufWriter.

fn decode<R>(r: &mut R) -> Result<ShardedGossipWire, Error>where R: Read,

Decode a reader into this item. You may wish to first wrap your reader in a BufReader.

fn encode_vec(&self) -> Result<Vec<u8, Global>, Error>

Encode this item to an owned vector of bytes. Uses encode() internally.

fn decode_ref(r: &[u8]) -> Result<(u64, Self), Error>

Decode a range of bytes into this item. Will also return the byte count read. Uses decode() internally.

impl Debug for ShardedGossipWire

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl PartialEq<ShardedGossipWire> for ShardedGossipWire

fn eq(&self, other: &ShardedGossipWire) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ShardedGossipWire