Struct solana_gossip::crds_gossip_push::CrdsGossipPush
source · pub struct CrdsGossipPush {
pub prune_timeout: u64,
pub num_total: AtomicUsize,
pub num_old: AtomicUsize,
pub num_pushes: AtomicUsize,
/* private fields */
}
Fields§
§prune_timeout: u64
§num_total: AtomicUsize
§num_old: AtomicUsize
§num_pushes: AtomicUsize
Implementations§
source§impl CrdsGossipPush
impl CrdsGossipPush
pub fn num_pending(&self, crds: &RwLock<Crds>) -> usize
sourcepub fn process_prune_msg(
&self,
self_pubkey: &Pubkey,
peer: &Pubkey,
origins: &[Pubkey]
)
pub fn process_prune_msg(
&self,
self_pubkey: &Pubkey,
peer: &Pubkey,
origins: &[Pubkey]
)
Add the from
to the peer’s filter of nodes.
Trait Implementations§
Auto Trait Implementations§
impl RefUnwindSafe for CrdsGossipPush
impl Send for CrdsGossipPush
impl Sync for CrdsGossipPush
impl Unpin for CrdsGossipPush
impl UnwindSafe for CrdsGossipPush
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request