Enum 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>, id: u32, agent_list: Vec<AgentInfoSigned> ) -> Self

Variant constructor helper function.

pub fn accept( intervals: Vec<DhtArcRange>, agent_list: Vec<AgentInfoSigned> ) -> Self

Variant constructor helper function.

pub fn agents(filter: PoolBuf) -> Self

Variant constructor helper function.

pub fn missing_agents(agents: Vec<Arc<AgentInfoSigned>>) -> Self

Variant constructor helper function.

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

Variant constructor helper function.

pub fn op_regions(region_set: RegionSetLtcs) -> Self

Variant constructor helper function.

pub fn missing_op_hashes(ops: Vec<OpHashSized>, finished: u8) -> Self

Variant constructor helper function.

pub fn op_batch_received() -> Self

Variant constructor helper function.

pub fn error(message: String) -> Self

Variant constructor helper function.

pub fn busy() -> Self

Variant constructor helper function.

pub fn no_agents() -> Self

Variant constructor helper function.

pub fn already_in_progress() -> Self

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<()>

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<Self, 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>, 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

Formats the value using the given formatter.

impl PartialEq 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