pub enum ShardedGossipWire {
Initiate(Initiate),
Accept(Accept),
Agents(Agents),
MissingAgents(MissingAgents),
Ops(Ops),
MissingOps(MissingOps),
NoAgents(NoAgents),
AlreadyInProgress(AlreadyInProgress),
Busy(Busy),
Error(Error),
OpsBatchReceived(OpsBatchReceived),
}
Expand description
SimpleBloom Gossip 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.
Ops(Ops)
Send Ops Bloom
MissingOps(MissingOps)
Any ops that were missing from the remote bloom.
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.
Busy(Busy)
The node currently is gossiping with too many other nodes and is too busy to accept your initiate. Please try again later.
Error(Error)
The node you are gossiping with has hit an error condition and failed to respond to a request.
OpsBatchReceived(OpsBatchReceived)
I have received a complete batch of missing ops and I am ready to receive the next batch.
Implementations
sourceimpl ShardedGossipWire
impl ShardedGossipWire
sourcepub fn initiate(
intervals: Vec<ArcInterval>,
id: u32,
agent_list: Vec<AgentInfoSigned>
) -> Self
pub fn initiate(
intervals: Vec<ArcInterval>,
id: u32,
agent_list: Vec<AgentInfoSigned>
) -> Self
Variant constructor helper function.
sourcepub fn accept(
intervals: Vec<ArcInterval>,
agent_list: Vec<AgentInfoSigned>
) -> Self
pub fn accept(
intervals: Vec<ArcInterval>,
agent_list: Vec<AgentInfoSigned>
) -> Self
Variant constructor helper function.
sourcepub fn missing_agents(agents: Vec<Arc<AgentInfoSigned>>) -> Self
pub fn missing_agents(agents: Vec<Arc<AgentInfoSigned>>) -> Self
Variant constructor helper function.
sourcepub fn ops(missing_hashes: EncodedTimedBloomFilter, finished: bool) -> Self
pub fn ops(missing_hashes: EncodedTimedBloomFilter, finished: bool) -> Self
Variant constructor helper function.
sourcepub fn missing_ops(
ops: Vec<(Arc<KitsuneOpHash>, Vec<u8>)>,
finished: u8
) -> Self
pub fn missing_ops(
ops: Vec<(Arc<KitsuneOpHash>, Vec<u8>)>,
finished: u8
) -> Self
Variant constructor helper function.
sourcepub fn already_in_progress() -> Self
pub fn already_in_progress() -> Self
Variant constructor helper function.
sourcepub fn ops_batch_received() -> Self
pub fn ops_batch_received() -> Self
Variant constructor helper function.
Trait Implementations
sourceimpl Clone for ShardedGossipWire
impl Clone for ShardedGossipWire
sourcefn clone(&self) -> ShardedGossipWire
fn clone(&self) -> ShardedGossipWire
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source
. Read more
sourceimpl Codec for ShardedGossipWire
impl Codec for ShardedGossipWire
sourcefn variant_type(&self) -> &'static str
fn variant_type(&self) -> &'static str
Variant identifier (for debugging or as a cheap discriminant).
sourcefn encode<W>(&self, w: &mut W) -> Result<()> where
W: Write,
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. Read more
sourcefn decode<R>(r: &mut R) -> Result<Self, Error> where
R: Read,
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. Read more
sourceimpl Debug for ShardedGossipWire
impl Debug for ShardedGossipWire
sourceimpl PartialEq<ShardedGossipWire> for ShardedGossipWire
impl PartialEq<ShardedGossipWire> for ShardedGossipWire
sourcefn eq(&self, other: &ShardedGossipWire) -> bool
fn eq(&self, other: &ShardedGossipWire) -> bool
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
sourcefn ne(&self, other: &ShardedGossipWire) -> bool
fn ne(&self, other: &ShardedGossipWire) -> bool
This method tests for !=
.
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
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
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>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<T> Pointable for T
impl<T> Pointable for T
sourceimpl<T> ToOwned for T where
T: Clone,
impl<T> ToOwned for T where
T: Clone,
type Owned = T
type Owned = T
The resulting type after obtaining ownership.
sourcepub fn to_owned(&self) -> T
pub fn to_owned(&self) -> T
Creates owned data from borrowed data, usually by cloning. Read more
sourcepub fn clone_into(&self, target: &mut T)
pub fn clone_into(&self, target: &mut T)
toowned_clone_into
)Uses borrowed data to replace owned data, usually by cloning. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
pub fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more