AccountsFile

Enum AccountsFile 

Source
pub enum AccountsFile {
    AppendVec(AppendVec),
    TieredStorage(TieredStorage),
}
Expand description

An enum for accessing an accounts file which can be implemented under different formats.

Variants§

§

AppendVec(AppendVec)

§

TieredStorage(TieredStorage)

Implementations§

Source§

impl AccountsFile

Source

pub fn new_for_startup( path: impl Into<PathBuf>, current_len: usize, storage_access: StorageAccess, ) -> Result<Self>

Creates a new AccountsFile for the underlying storage at path

This version of new() may only be called when reconstructing storages as part of startup. It trusts the snapshot’s value for current_len, and relies on later index generation or accounts verification to ensure it is valid.

Source

pub fn flush(&self) -> Result<()>

Source

pub fn reset(&self)

Source

pub fn remaining_bytes(&self) -> u64

Source

pub fn len(&self) -> usize

Source

pub fn is_empty(&self) -> bool

Source

pub fn capacity(&self) -> u64

Source

pub fn file_name(slot: Slot, id: AccountsFileId) -> String

Source

pub fn get_stored_account_without_data_callback<Ret>( &self, offset: usize, callback: impl for<'local> FnMut(StoredAccountInfoWithoutData<'local>) -> Ret, ) -> Option<Ret>

Calls callback with the stored account at offset.

Returns None if there is no account at offset, otherwise returns the result of callback in Some.

This fn does not load the account’s data, just the data length. If the data is needed, use get_stored_account_callback() instead. However, prefer this fn when possible.

Source

pub fn get_stored_account_callback<Ret>( &self, offset: usize, callback: impl for<'local> FnMut(StoredAccountInfo<'local>) -> Ret, ) -> Option<Ret>

Calls callback with the stored account at offset.

Returns None if there is no account at offset, otherwise returns the result of callback in Some.

This fn does load the account’s data. If the data is not needed, use get_stored_account_without_data_callback() instead.

Source

pub fn path(&self) -> &Path

Return the path of the underlying account file.

Source

pub fn scan_accounts_without_data( &self, callback: impl for<'local> FnMut(Offset, StoredAccountInfoWithoutData<'local>), ) -> Result<()>

Iterate over all accounts and call callback with each account.

callback parameters:

  • Offset: the offset within the file of this account
  • StoredAccountInfoWithoutData: the account itself, without account data

Note that account data is not read/passed to the callback.

Source

pub fn scan_pubkeys(&self, callback: impl FnMut(&Pubkey)) -> Result<()>

iterate over all pubkeys

Source

pub fn write_accounts<'a>( &self, accounts: &impl StorableAccounts<'a>, skip: usize, ) -> Option<StoredAccountsInfo>

Copy each account metadata, account and hash to the internal buffer. If there is no room to write the first entry, None is returned. Otherwise, returns the starting offset of each account metadata. Plus, the final return value is the offset where the next entry would be appended. So, return.len() is 1 + (number of accounts written) After each account is appended, the internal current_len is updated and will be available to other threads.

Source

pub fn internals_for_archive(&self) -> InternalsForArchive<'_>

Returns the way to access this accounts file when archiving

Trait Implementations§

Source§

impl Debug for AccountsFile

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

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> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

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> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

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>,

Source§

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

impl<T> ErasedDestructor for T
where T: 'static,

Source§

impl<T> MaybeSendSync for T