Struct solana_storage_bigtable::LedgerStorage

pub struct LedgerStorage {
    pub(crate) connection: BigTableConnection,
}

Fields

connection: BigTableConnection

Implementations

impl LedgerStorage

pub async fn new( read_only: bool, timeout: Option<Duration>, credential_path: Option<String> ) -> Result<Self>

pub fn new_for_emulator( instance_name: &str, app_profile_id: &str, endpoint: &str, timeout: Option<Duration> ) -> Result<Self>

pub async fn new_with_config(config: LedgerStorageConfig) -> Result<Self>

pub async fn new_with_stringified_credential(credential: String) -> Result<Self>

pub async fn get_first_available_block(&self) -> Result<Option<Slot>>

Return the available slot that contains a block

pub async fn get_confirmed_blocks( &self, start_slot: Slot, limit: usize ) -> Result<Vec<Slot>>

Fetch the next slots after the provided slot that contains a block

start_slot: slot to start the search from (inclusive) limit: stop after this many slots have been found

pub async fn get_confirmed_blocks_with_data<'a>( &self, slots: &'a [Slot] ) -> Result<impl Iterator<Item = (Slot, ConfirmedBlock)> + 'a>

pub async fn get_confirmed_block(&self, slot: Slot) -> Result<ConfirmedBlock>

Fetch the confirmed block from the desired slot

pub async fn confirmed_block_exists(&self, slot: Slot) -> Result<bool>

Does the confirmed block exist in the Bigtable

pub async fn get_signature_status( &self, signature: &Signature ) -> Result<TransactionStatus>

pub async fn get_confirmed_transactions( &self, signatures: &[Signature] ) -> Result<Vec<ConfirmedTransactionWithStatusMeta>>

pub async fn get_confirmed_transaction( &self, signature: &Signature ) -> Result<Option<ConfirmedTransactionWithStatusMeta>>

Fetch a confirmed transaction

pub async fn get_confirmed_signatures_for_address( &self, address: &Pubkey, before_signature: Option<&Signature>, until_signature: Option<&Signature>, limit: usize ) -> Result<Vec<(ConfirmedTransactionStatusWithSignature, u32)>>

Get confirmed signatures for the provided address, in descending ledger order

address: address to search for before_signature: start with the first signature older than this one until_signature: end with the last signature more recent than this one limit: stop after this many signatures; if limit==0, all records in the table will be read

pub async fn upload_confirmed_block( &self, slot: Slot, confirmed_block: VersionedConfirmedBlock ) -> Result<()>

pub async fn delete_confirmed_block( &self, slot: Slot, dry_run: bool ) -> Result<()>

Trait Implementations

impl Clone for LedgerStorage

fn clone(&self) -> LedgerStorage

Returns a copy of the value.

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

Performs copy-assignment from source.