Struct solana_core::crds::Crds

pub struct Crds {
    pub num_inserts: usize,
    // some fields omitted
}

Fields

num_inserts: usize

Implementations

impl Crds

pub fn new_versioned(
    &self,
    local_timestamp: u64,
    value: CrdsValue
) -> VersionedCrdsValue

must be called atomically with insert_versioned

pub fn would_insert(
    &self,
    value: CrdsValue,
    local_timestamp: u64
) -> (bool, VersionedCrdsValue)

pub fn insert_versioned(
    &mut self,
    new_value: VersionedCrdsValue
) -> Result<Option<VersionedCrdsValue>, CrdsError>

insert the new value, returns the old value if insert succeeds

pub fn insert(
    &mut self,
    value: CrdsValue,
    local_timestamp: u64
) -> Result<Option<VersionedCrdsValue>, CrdsError>

pub fn lookup(&self, label: &CrdsValueLabel) -> Option<&CrdsValue>

pub fn lookup_versioned(
    &self,
    label: &CrdsValueLabel
) -> Option<&VersionedCrdsValue>

pub fn get(&self, label: &CrdsValueLabel) -> Option<&VersionedCrdsValue>

pub fn get_contact_info(&self, pubkey: Pubkey) -> Option<&ContactInfo>

pub fn get_lowest_slot(&self, pubkey: Pubkey) -> Option<&LowestSlot>

pub fn get_nodes(&self) -> impl Iterator<Item = &VersionedCrdsValue>

Returns all entries which are ContactInfo.

pub fn get_nodes_contact_info(&self) -> impl Iterator<Item = &ContactInfo>

Returns ContactInfo of all known nodes.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn par_values(&self) -> ParValues<'_, CrdsValueLabel, VersionedCrdsValue>

pub fn filter_bitmask(
    &self,
    mask: u64,
    mask_bits: u32
) -> impl Iterator<Item = &VersionedCrdsValue>

Returns all crds values which the first ‘mask_bits’ of their hash value is equal to ‘mask’.

pub fn update_record_timestamp(&mut self, pubkey: &Pubkey, now: u64)

Update the timestamp’s of all the labels that are associated with Pubkey

pub fn find_old_labels(
    &self,
    thread_pool: &ThreadPool,
    now: u64,
    timeouts: &HashMap<Pubkey, u64>
) -> Vec<CrdsValueLabel>

Find all the keys that are older or equal to the timeout.

• timeouts - Pubkey specific timeouts with Pubkey::default() as the default timeout.

pub fn remove(&mut self, key: &CrdsValueLabel) -> Option<VersionedCrdsValue>

Trait Implementations

impl Clone for Crds

fn clone(&self) -> Crds

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Crds

fn default() -> Self

Returns the “default value” for a type.