Struct solana_storage_bigtable::LedgerStorage

pub struct LedgerStorage { /* private fields */ }

Implementations

impl LedgerStorage

pub async fn new(
    read_only: bool,
    timeout: Option<Duration>,
    credential_path: Option<String>
) -> 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; if limit==0, all records in the table after start_slot will be read

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 get_signature_status(
    &self,
    signature: &Signature
) -> Result<TransactionStatus>

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.