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),
}
Expand description
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§
source§impl ShardedGossipWire
impl ShardedGossipWire
sourcepub fn initiate(
intervals: Vec<DhtArcRange<DhtLocation>, Global>,
id: u32,
agent_list: Vec<AgentInfoSigned, Global>
) -> ShardedGossipWire
pub fn initiate( intervals: Vec<DhtArcRange<DhtLocation>, Global>, id: u32, agent_list: Vec<AgentInfoSigned, Global> ) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn accept(
intervals: Vec<DhtArcRange<DhtLocation>, Global>,
agent_list: Vec<AgentInfoSigned, Global>
) -> ShardedGossipWire
pub fn accept( intervals: Vec<DhtArcRange<DhtLocation>, Global>, agent_list: Vec<AgentInfoSigned, Global> ) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn agents(filter: PoolBuf) -> ShardedGossipWire
pub fn agents(filter: PoolBuf) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn missing_agents(
agents: Vec<Arc<AgentInfoSigned, Global>, Global>
) -> ShardedGossipWire
pub fn missing_agents( agents: Vec<Arc<AgentInfoSigned, Global>, Global> ) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn op_bloom(
missing_hashes: EncodedTimedBloomFilter,
finished: bool
) -> ShardedGossipWire
pub fn op_bloom( missing_hashes: EncodedTimedBloomFilter, finished: bool ) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn op_regions(region_set: RegionSetLtcs<RegionData>) -> ShardedGossipWire
pub fn op_regions(region_set: RegionSetLtcs<RegionData>) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn missing_op_hashes(
ops: Vec<RoughSized<Arc<KitsuneOpHash, Global>>, Global>,
finished: u8
) -> ShardedGossipWire
pub fn missing_op_hashes( ops: Vec<RoughSized<Arc<KitsuneOpHash, Global>>, Global>, finished: u8 ) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn op_batch_received() -> ShardedGossipWire
pub fn op_batch_received() -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn error(message: String) -> ShardedGossipWire
pub fn error(message: String) -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn busy() -> ShardedGossipWire
pub fn busy() -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn no_agents() -> ShardedGossipWire
pub fn no_agents() -> ShardedGossipWire
Variant constructor helper function.
sourcepub fn already_in_progress() -> ShardedGossipWire
pub fn already_in_progress() -> ShardedGossipWire
Variant constructor helper function.
Trait Implementations§
source§impl Clone for ShardedGossipWire
impl Clone for ShardedGossipWire
source§fn clone(&self) -> ShardedGossipWire
fn clone(&self) -> ShardedGossipWire
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Codec for ShardedGossipWire
impl Codec for ShardedGossipWire
source§fn variant_type(&self) -> &'static str
fn variant_type(&self) -> &'static str
source§fn encode<W>(&self, w: &mut W) -> Result<(), Error>where
W: Write,
fn encode<W>(&self, w: &mut W) -> Result<(), Error>where W: Write,
source§fn decode<R>(r: &mut R) -> Result<ShardedGossipWire, Error>where
R: Read,
fn decode<R>(r: &mut R) -> Result<ShardedGossipWire, Error>where R: Read,
source§impl Debug for ShardedGossipWire
impl Debug for ShardedGossipWire
source§impl PartialEq<ShardedGossipWire> for ShardedGossipWire
impl PartialEq<ShardedGossipWire> for ShardedGossipWire
source§fn eq(&self, other: &ShardedGossipWire) -> bool
fn eq(&self, other: &ShardedGossipWire) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for ShardedGossipWire
Auto Trait Implementations§
impl RefUnwindSafe for ShardedGossipWire
impl Send for ShardedGossipWire
impl Sync for ShardedGossipWire
impl Unpin for ShardedGossipWire
impl UnwindSafe for ShardedGossipWire
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata ) -> <T as Pointee>::Metadata
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<F, W, T, D> Deserialize<With<T, W>, D> for Fwhere
W: DeserializeWith<F, T, D>,
D: Fallible + ?Sized,
F: ?Sized,
impl<F, W, T, D> Deserialize<With<T, W>, D> for Fwhere W: DeserializeWith<F, T, D>, D: Fallible + ?Sized, F: ?Sized,
§fn deserialize(
&self,
deserializer: &mut D
) -> Result<With<T, W>, <D as Fallible>::Error>
fn deserialize( &self, deserializer: &mut D ) -> Result<With<T, W>, <D as Fallible>::Error>
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
§impl<T> Pointable for T
impl<T> Pointable for T
§impl<SS, SP> SupersetOf<SS> for SPwhere
SS: SubsetOf<SP>,
impl<SS, SP> SupersetOf<SS> for SPwhere SS: SubsetOf<SP>,
§fn to_subset(&self) -> Option<SS>
fn to_subset(&self) -> Option<SS>
self
from the equivalent element of its
superset. Read more§fn is_in_subset(&self) -> bool
fn is_in_subset(&self) -> bool
self
is actually part of its subset T
(and can be converted to it).§fn to_subset_unchecked(&self) -> SS
fn to_subset_unchecked(&self) -> SS
self.to_subset
but without any property checks. Always succeeds.§fn from_subset(element: &SS) -> SP
fn from_subset(element: &SS) -> SP
self
to the equivalent element of its superset.