Struct AccountsIndexStorage

pub struct AccountsIndexStorage<T: IndexValue, U: DiskIndexValue + From<T> + Into<T>> {
    pub storage: Arc<BucketMapHolder<T, U>>,
    pub in_mem: Vec<Arc<InMemAccountsIndex<T, U>>>,
    /* private fields */
}

Manages the lifetime of the background processing threads.

Fields

storage: Arc<BucketMapHolder<T, U>>

in_mem: Vec<Arc<InMemAccountsIndex<T, U>>>

Implementations

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

pub fn set_startup(&self, startup: Startup)

startup=true causes: in mem to act in a way that flushes to disk asap also creates some additional bg threads to facilitate flushing to disk asap startup=false is ‘normal’ operation

pub fn get_startup_remaining_items_to_flush_estimate(&self) -> usize

estimate how many items are still needing to be flushed to the disk cache.

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

allocate BucketMapHolder and InMemAccountsIndex[]

Trait Implementations

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

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

Formats the value using the given formatter.