pub struct AccountsIndex<T: IndexValue, U: DiskIndexValue + From<T> + Into<T>> {
    pub account_maps: Vec<AccountMap<T, U>>,
    pub bin_calculator: PubkeyBinCalculator24,
    pub roots_tracker: RwLock<RootsTracker>,
    pub removed_bank_ids: Mutex<HashSet<BankId>>,
    pub scan_results_limit_bytes: Option<usize>,
    pub roots_added: AtomicUsize,
    pub roots_removed: AtomicUsize,
    pub active_scans: AtomicUsize,
    pub max_distance_to_min_scan_slot: AtomicU64,
    pub rent_paying_accounts_by_partition: OnceLock<RentPayingAccountsByPartition>,
    /* private fields */
}
Expand description

T: account info type to interact in in-memory items U: account info type to be persisted to disk

Fields§

§account_maps: Vec<AccountMap<T, U>>§bin_calculator: PubkeyBinCalculator24§roots_tracker: RwLock<RootsTracker>§removed_bank_ids: Mutex<HashSet<BankId>>§scan_results_limit_bytes: Option<usize>

when a scan’s accumulated data exceeds this limit, abort the scan

§roots_added: AtomicUsize

§roots added since last check

§roots_removed: AtomicUsize

§roots removed since last check

§active_scans: AtomicUsize

§scans active currently

§max_distance_to_min_scan_slot: AtomicU64

§of slots between latest max and latest scan

§rent_paying_accounts_by_partition: OnceLock<RentPayingAccountsByPartition>

populated at generate_index time - accounts that could possibly be rent paying

Implementations§

source§

impl<T: IndexValue, U: DiskIndexValue + From<T> + Into<T>> AccountsIndex<T, U>

source

pub fn default_for_tests() -> Self

source

pub fn new(config: Option<AccountsIndexConfig>, exit: Arc<AtomicBool>) -> Self

source

pub fn is_disk_index_enabled(&self) -> bool

is the accounts index using disk as a backing store

source

pub fn get_account_read_entry( &self, pubkey: &Pubkey ) -> Option<ReadAccountMapEntry<T>>

source

pub fn get_account_read_entry_with_lock( &self, pubkey: &Pubkey, lock: &&'_ AccountMap<T, U> ) -> Option<ReadAccountMapEntry<T>>

source

pub fn handle_dead_keys( &self, dead_keys: &[&Pubkey], account_indexes: &AccountSecondaryIndexes ) -> HashSet<Pubkey>

Remove keys from the account index if the key’s slot list is empty. Returns the keys that were removed from the index. These keys should not be accessed again in the current code path.

source

pub fn get_rooted_entries( &self, slice: SlotSlice<'_, T>, max_inclusive: Option<Slot> ) -> SlotList<T>

source

pub fn min_ongoing_scan_root(&self) -> Option<Slot>

source

pub fn hold_range_in_memory<R>( &self, range: &R, start_holding: bool, thread_pool: &ThreadPool )
where R: RangeBounds<Pubkey> + Debug + Sync,

source

pub fn set_startup(&self, value: Startup)

source

pub fn get_startup_remaining_items_to_flush_estimate(&self) -> usize

source

pub fn get( &self, pubkey: &Pubkey, ancestors: Option<&Ancestors>, max_root: Option<Slot> ) -> AccountIndexGetResult<T>

Get an account The latest account that appears in ancestors or roots is returned.

source

pub fn get_index_key_size( &self, index: &AccountIndex, index_key: &Pubkey ) -> Option<usize>

source

pub fn bins(&self) -> usize

source

pub fn upsert( &self, new_slot: Slot, old_slot: Slot, pubkey: &Pubkey, account: &impl ReadableAccount, account_indexes: &AccountSecondaryIndexes, account_info: T, reclaims: &mut SlotList<T>, reclaim: UpsertReclaim )

Updates the given pubkey at the given slot with the new account information. on return, the index’s previous account info may be returned in ‘reclaims’ depending on ‘previous_slot_entry_was_cached’

source

pub fn ref_count_from_storage(&self, pubkey: &Pubkey) -> RefCount

source

pub fn clean_rooted_entries( &self, pubkey: &Pubkey, reclaims: &mut SlotList<T>, max_clean_root_inclusive: Option<Slot> ) -> bool

return true if pubkey was removed from the accounts index or does not exist in the accounts index This means it should NOT be unref’d later.

source

pub fn get_rooted_from_list<'a>( &self, slots: impl Iterator<Item = &'a Slot> ) -> Vec<Slot>

Given a list of slots, return a new list of only the slots that are rooted

source

pub fn is_alive_root(&self, slot: Slot) -> bool

source

pub fn add_root(&self, slot: Slot)

source

pub fn add_uncleaned_roots<I>(&self, roots: I)
where I: IntoIterator<Item = Slot>,

source

pub fn max_root_inclusive(&self) -> Slot

source

pub fn clean_dead_slot(&self, slot: Slot) -> bool

Remove the slot when the storage for the slot is freed Accounts no longer reference this slot. return true if slot was a root

source

pub fn min_alive_root(&self) -> Option<Slot>

source

pub fn num_alive_roots(&self) -> usize

source

pub fn all_alive_roots(&self) -> Vec<Slot>

source

pub fn clone_uncleaned_roots(&self) -> IntSet<Slot>

source

pub fn uncleaned_roots_len(&self) -> usize

Trait Implementations§

source§

impl<T: Debug + IndexValue, U: Debug + DiskIndexValue + From<T> + Into<T>> Debug for AccountsIndex<T, U>

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<T, U> !Freeze for AccountsIndex<T, U>

§

impl<T, U> !RefUnwindSafe for AccountsIndex<T, U>

§

impl<T, U> Send for AccountsIndex<T, U>

§

impl<T, U> Sync for AccountsIndex<T, U>

§

impl<T, U> Unpin for AccountsIndex<T, U>

§

impl<T, U> !UnwindSafe for AccountsIndex<T, U>

Blanket Implementations§

source§

impl<T> AbiExample for T

source§

default fn example() -> T

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Pointable for T

source§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

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
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more