Enum holochain::prelude::gossip::sharded_gossip::ShardedGossipWire
source · pub enum ShardedGossipWire {
Initiate(Initiate),
Accept(Accept),
Agents(Agents),
MissingAgents(MissingAgents),
OpBloom(OpBloom),
OpRegions(OpRegions),
MissingOps(MissingOps),
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
MissingOps(MissingOps)
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
sourceimpl 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>
) -> ShardedGossipWire
pub fn missing_agents(
agents: Vec<Arc<AgentInfoSigned>, 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_ops(
ops: Vec<Arc<KitsuneOpData>, Global>,
finished: u8
) -> ShardedGossipWire
pub fn missing_ops(
ops: Vec<Arc<KitsuneOpData>, 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
sourceimpl Clone for ShardedGossipWire
impl Clone for ShardedGossipWire
sourcefn clone(&self) -> ShardedGossipWire
fn clone(&self) -> ShardedGossipWire
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresourceimpl Codec for ShardedGossipWire
impl Codec for ShardedGossipWire
sourcefn variant_type(&self) -> &'static str
fn variant_type(&self) -> &'static str
sourcefn encode<W>(&self, w: &mut W) -> Result<(), Error>where
W: Write,
fn encode<W>(&self, w: &mut W) -> Result<(), Error>where
W: Write,
sourcefn decode<R>(r: &mut R) -> Result<ShardedGossipWire, Error>where
R: Read,
fn decode<R>(r: &mut R) -> Result<ShardedGossipWire, Error>where
R: Read,
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
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> Any for Twhere
T: Any + ?Sized,
impl<T> Any for Twhere
T: Any + ?Sized,
fn type_id_compat(&self) -> TypeId
fn type_id_compat(&self) -> TypeId
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
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn 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> ⓘ
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> ⓘ
sourcefn 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 morefn 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.