Struct solana_gossip::crds_gossip_push::CrdsGossipPush [−][src]
pub struct CrdsGossipPush { pub max_bytes: usize, pub num_active: usize, pub push_fanout: usize, pub msg_timeout: u64, pub prune_timeout: u64, pub num_total: usize, pub num_old: usize, pub num_pushes: usize, // some fields omitted }
Fields
max_bytes: usize
max bytes per message
num_active: usize
push_fanout: usize
msg_timeout: u64
prune_timeout: u64
num_total: usize
num_old: usize
num_pushes: usize
Implementations
pub fn prune_received_cache(
&mut self,
self_pubkey: &Pubkey,
origin: &Pubkey,
stakes: &HashMap<Pubkey, u64>
) -> Vec<Pubkey>
[src]pub fn process_push_message(
&mut self,
crds: &mut Crds,
from: &Pubkey,
value: CrdsValue,
now: u64
) -> Result<(), CrdsGossipError>
[src]
pub fn process_push_message(
&mut self,
crds: &mut Crds,
from: &Pubkey,
value: CrdsValue,
now: u64
) -> Result<(), CrdsGossipError>
[src]process a push message to the network
New push message to broadcast to peers. Returns a list of Pubkeys for the selected peers and a list of values to send to all the peers. The list of push messages is created such that all the randomly selected peers have not pruned the source addresses.
add the from
to the peer’s filter of nodes
refresh the push active set
- ratio - active_set.len()/ratio is the number of actives to rotate
purge received push message cache
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
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Wrap the input message T
in a tonic::Request
type Output = T
type Output = T
Should always be Self
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more