Struct diem_data_client::diemnet::DiemNetDataClient

pub struct DiemNetDataClient { /* fields omitted */ }

A DiemDataClient that fulfills requests from remote peers’ Storage Service over DiemNet.

The DiemNetDataClient:

1. Sends requests to connected DiemNet 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 DiemNetDataClient

pub fn new(
    data_client_config: DiemDataClientConfig,
    storage_service_config: StorageServiceConfig,
    time_service: TimeService,
    network_client: StorageServiceClient
) -> (Self, DataSummaryPoller)

Trait Implementations

impl Clone for DiemNetDataClient

fn clone(&self) -> DiemNetDataClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DiemNetDataClient

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

Formats the value using the given formatter.

impl DiemDataClient for DiemNetDataClient

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<AccountStatesChunkWithProof>>> + 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_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.