Struct FetchClient 

pub struct FetchClient<N = BasicNetworkPrimitives<EthPrimitives, EthereumTxEnvelope<TxEip4844WithSidecar>>>
where
    N: NetworkPrimitives,
{ /* private fields */ }

Available on crate feature network only.

Front-end API for fetching data from the network.

Following diagram illustrates how a request, See HeadersClient::get_headers and BodiesClient::get_block_bodies is handled internally.

include_mmd!(“docs/mermaid/fetch-client.mmd”)

Trait Implementations

impl<N> BlockAccessListsClient for FetchClient<N>

where N: NetworkPrimitives,

type Output = Either<FlattenedResponse<Result<WithPeerId<BlockAccessLists>, RequestError>>, Ready<Result<WithPeerId<BlockAccessLists>, RequestError>>>

The bal type this client fetches.

fn get_block_access_lists_with_priority_and_requirement( &self, hashes: Vec<FixedBytes<32>>, priority: Priority, requirement: BalRequirement, ) -> <FetchClient<N> as BlockAccessListsClient>::Output

Fetches the block access lists for given hashes with priority and BAL availability policy.

fn get_block_access_lists(&self, hashes: Vec<FixedBytes<32>>) -> Self::Output

Fetches the block access lists for given hashes.

fn get_block_access_lists_with_requirement( &self, hashes: Vec<FixedBytes<32>>, requirement: BalRequirement, ) -> Self::Output

Fetches the block access lists for given hashes with the requested BAL availability policy.

fn get_block_access_lists_with_priority( &self, hashes: Vec<FixedBytes<32>>, priority: Priority, ) -> Self::Output

Fetches the block access lists for given hashes with priority

impl<N> BlockClient for FetchClient<N>

where N: NetworkPrimitives,

type Block = <N as NetworkPrimitives>::Block

The Block type that this client fetches.

impl<N> BodiesClient for FetchClient<N>

where N: NetworkPrimitives,

fn get_block_bodies_with_priority_and_range_hint( &self, request: Vec<FixedBytes<32>>, priority: Priority, range_hint: Option<RangeInclusive<u64>>, ) -> <FetchClient<N> as BodiesClient>::Output

Sends a GetBlockBodies request to an available peer.

type Body = <N as NetworkPrimitives>::BlockBody

The body type this client fetches.

type Output = Either<FlattenedResponse<Result<WithPeerId<Vec<<N as NetworkPrimitives>::BlockBody>>, RequestError>>, Ready<Result<WithPeerId<Vec<<N as NetworkPrimitives>::BlockBody>>, RequestError>>>

The output of the request future for querying block bodies.

fn get_block_bodies(&self, hashes: Vec<FixedBytes<32>>) -> Self::Output

Fetches the block body for the requested block.

fn get_block_bodies_with_priority( &self, hashes: Vec<FixedBytes<32>>, priority: Priority, ) -> Self::Output

Fetches the block body for the requested block with priority

fn get_block_body( &self, hash: FixedBytes<32>, ) -> SingleBodyRequest<Self::Output>

Fetches a single block body for the requested hash.

fn get_block_body_with_priority( &self, hash: FixedBytes<32>, priority: Priority, ) -> SingleBodyRequest<Self::Output>

Fetches a single block body for the requested hash with priority

impl<N> Clone for FetchClient<N>

where N: Clone + NetworkPrimitives,

fn clone(&self) -> FetchClient<N>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<N> Debug for FetchClient<N>

where N: Debug + NetworkPrimitives,

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

Formats the value using the given formatter.

impl<N> DownloadClient for FetchClient<N>

where N: NetworkPrimitives,

fn report_bad_message(&self, peer_id: FixedBytes<64>)

Penalize the peer for responding with a message that violates validation rules

fn num_connected_peers(&self) -> usize

Returns how many peers the network is currently connected to.

impl<N> HeadersClient for FetchClient<N>

where N: NetworkPrimitives,

fn get_headers_with_priority( &self, request: HeadersRequest, priority: Priority, ) -> <FetchClient<N> as HeadersClient>::Output

Sends a GetBlockHeaders request to an available peer.

type Header = <N as NetworkPrimitives>::BlockHeader

The header type this client fetches.

type Output = Either<FlattenedResponse<Result<WithPeerId<Vec<<N as NetworkPrimitives>::BlockHeader>>, RequestError>>, Ready<Result<WithPeerId<Vec<<N as NetworkPrimitives>::BlockHeader>>, RequestError>>>

The headers future type

fn get_headers(&self, request: HeadersRequest) -> Self::Output

Sends the header request to the p2p network and returns the header response received from a peer.

fn get_header(&self, start: HashOrNumber) -> SingleHeaderRequest<Self::Output>

Fetches a single header for the requested number or hash.

fn get_header_with_priority( &self, start: HashOrNumber, priority: Priority, ) -> SingleHeaderRequest<Self::Output>

Fetches a single header for the requested number or hash with priority

impl<N> ReceiptsClient for FetchClient<N>

where N: NetworkPrimitives,

type Receipt = <N as NetworkPrimitives>::Receipt

The receipt type this client fetches.

type Output = Either<FlattenedResponse<Result<WithPeerId<ReceiptsResponse<<N as NetworkPrimitives>::Receipt>>, RequestError>>, Ready<Result<WithPeerId<ReceiptsResponse<<N as NetworkPrimitives>::Receipt>>, RequestError>>>

The output of the request future for querying block receipts.

fn get_receipts_with_priority( &self, request: Vec<FixedBytes<32>>, priority: Priority, ) -> <FetchClient<N> as ReceiptsClient>::Output

Fetches the receipts for the requested block hashes with priority.

fn get_receipts(&self, hashes: Vec<FixedBytes<32>>) -> Self::Output

Fetches the receipts for the requested block hashes.

impl<N> SnapClient for FetchClient<N>

where N: NetworkPrimitives,

fn get_account_range_with_priority( &self, request: GetAccountRangeMessage, priority: Priority, ) -> <FetchClient<N> as SnapClient>::Output

Sends a GetAccountRange (snap/2) request to an available peer.

fn get_storage_ranges( &self, request: GetStorageRangesMessage, ) -> <FetchClient<N> as SnapClient>::Output

Sends a GetStorageRanges (snap/2) request to an available peer.

fn get_storage_ranges_with_priority( &self, request: GetStorageRangesMessage, priority: Priority, ) -> <FetchClient<N> as SnapClient>::Output

Sends a GetStorageRanges (snap/2) request to an available peer.

fn get_byte_codes( &self, request: GetByteCodesMessage, ) -> <FetchClient<N> as SnapClient>::Output

Sends a GetByteCodes (snap/2) request to an available peer.

fn get_byte_codes_with_priority( &self, request: GetByteCodesMessage, priority: Priority, ) -> <FetchClient<N> as SnapClient>::Output

Sends a GetByteCodes (snap/2) request to an available peer.

fn get_block_access_lists_with_priority( &self, request: GetBlockAccessListsMessage, priority: Priority, ) -> <FetchClient<N> as SnapClient>::Output

Sends a GetBlockAccessLists (snap/2) request to an available peer.

type Output = Either<FlattenedResponse<Result<WithPeerId<SnapResponse>, RequestError>>, Ready<Result<WithPeerId<SnapResponse>, RequestError>>>

The output future type for snap requests

fn get_account_range(&self, request: GetAccountRangeMessage) -> Self::Output

Sends the account range request to the p2p network and returns the account range response received from a peer.

fn get_block_access_lists( &self, request: GetBlockAccessListsMessage, ) -> Self::Output

Sends the block access lists request to the p2p network and returns the block access lists response received from a peer.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 24 bytes