Struct aptos_data_client::aptosnet::AptosNetDataClient

pub struct AptosNetDataClient { /* private fields */ }

An AptosDataClient that fulfills requests from remote peers’ Storage Service over AptosNet.

The AptosNetDataClient:

1. Sends requests to connected Aptos peers.
2. Does basic type conversions and error handling on the responses.
3. Routes requests to peers that advertise availability for that data.
4. Maintains peer scores based on each peer’s observed quality of service and upper client reports of invalid or malicious data.
5. Selects high quality peers to send each request to.
6. Exposes a condensed data summary of our peers’ data advertisements.

The client currently assumes 1-request => 1-response. Streaming responses are handled at an upper layer.

The client is expected to be cloneable and usable from many concurrent tasks and/or threads.

Implementations

impl AptosNetDataClient

pub fn new(
    data_client_config: AptosDataClientConfig,
    storage_service_config: StorageServiceConfig,
    time_service: TimeService,
    network_client: StorageServiceClient,
    runtime: Option<Handle>
) -> (Self, DataSummaryPoller)

Trait Implementations

impl AptosDataClient for AptosNetDataClient

fn get_global_data_summary(&self) -> GlobalDataSummary

Returns a global summary of the data currently available in the network.

fn get_account_states_with_proof<'life0, 'async_trait>(
    &'life0 self,
    version: u64,
    start_account_index: u64,
    end_account_index: u64
) -> Pin<Box<dyn Future<Output = Result<Response<StateValueChunkWithProof>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns a single account states chunk with proof, containing the accounts from start to end index (inclusive) at the specified version. The proof version is the same as the specified version.

fn get_epoch_ending_ledger_infos<'life0, 'async_trait>(
    &'life0 self,
    start_epoch: Epoch,
    expected_end_epoch: Epoch
) -> Pin<Box<dyn Future<Output = Result<Response<Vec<LedgerInfoWithSignatures>>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns all epoch ending ledger infos between start and end (inclusive). If the data cannot be fetched (e.g., the number of epochs is too large), an error is returned.

fn get_new_transaction_outputs_with_proof<'life0, 'async_trait>(
    &'life0 self,
    known_version: Version,
    known_epoch: Epoch
) -> Pin<Box<dyn Future<Output = Result<Response<(TransactionOutputListWithProof, LedgerInfoWithSignatures)>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns a new transaction output list with proof. Versions start at known_version + 1 and known_epoch (inclusive). The end version and proof version are specified by the server. If the data cannot be fetched, an error is returned.

fn get_new_transactions_with_proof<'life0, 'async_trait>(
    &'life0 self,
    known_version: Version,
    known_epoch: Epoch,
    include_events: bool
) -> Pin<Box<dyn Future<Output = Result<Response<(TransactionListWithProof, LedgerInfoWithSignatures)>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns a new transaction list with proof. Versions start at known_version + 1 and known_epoch (inclusive). The end version and proof version are specified by the server. If the data cannot be fetched, an error is returned.

fn get_number_of_account_states<'life0, 'async_trait>(
    &'life0 self,
    version: Version
) -> Pin<Box<dyn Future<Output = Result<Response<u64>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns the number of account states at the specified version.

fn get_transaction_outputs_with_proof<'life0, 'async_trait>(
    &'life0 self,
    proof_version: Version,
    start_version: Version,
    end_version: Version
) -> Pin<Box<dyn Future<Output = Result<Response<TransactionOutputListWithProof>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns a transaction output list with proof object, with transaction outputs from start to end versions (inclusive). The proof is relative to the specified proof_version. If the data cannot be fetched (e.g., the number of transaction outputs is too large), an error is returned.

fn get_transactions_with_proof<'life0, 'async_trait>(
    &'life0 self,
    proof_version: Version,
    start_version: Version,
    end_version: Version,
    include_events: bool
) -> Pin<Box<dyn Future<Output = Result<Response<TransactionListWithProof>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Returns a transaction list with proof object, with transactions from start to end versions (inclusive). The proof is relative to the specified proof_version. If include_events is true, events are included in the proof. If the data cannot be fetched (e.g., the number of transactions is too large), an error is returned.

impl Clone for AptosNetDataClient

fn clone(&self) -> AptosNetDataClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AptosNetDataClient

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

Formats the value using the given formatter.