Struct storage_service_client::StorageServiceClient

pub struct StorageServiceClient { /* fields omitted */ }

The interface for sending Storage Service requests and querying network peer information.

Implementations

impl StorageServiceClient

pub fn new(
    network_sender: StorageServiceMultiSender,
    peer_metadata: Arc<PeerMetadataStorage>
) -> Self

pub async fn send_request(
    &self,
    recipient: PeerNetworkId,
    request: StorageServiceRequest,
    timeout: Duration
) -> Result<StorageServiceResponse, Error>

Trait Implementations

impl Clone for StorageServiceClient

fn clone(&self) -> StorageServiceClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StorageServiceClient

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

Formats the value using the given formatter.

impl NetworkInterface<StorageServiceMessage, MultiNetworkSender<StorageServiceMessage, StorageServiceNetworkSender>> for StorageServiceClient

type AppDataKey = ()

The application specific key for AppData

type AppData = ()

The application specific data to be stored

fn peer_metadata_storage(&self) -> &PeerMetadataStorage

Provides the PeerMetadataStorage for other functions. Not expected to be used externally.

fn sender(&self) -> StorageServiceMultiSender

Give a copy of the sender for the network

fn app_data(&self) -> &LockingHashMap<Self::AppDataKey, Self::AppData>

Application specific data interface

fn connected_peers(
    &self,
    network_id: NetworkId
) -> HashMap<PeerNetworkId, PeerInfo, RandomState>

Retrieve only connected peers

fn filtered_peers<F>(
    &self,
    network_id: NetworkId,
    filter: F
) -> HashMap<PeerNetworkId, PeerInfo, RandomState> where
    F: FnMut(&(&AccountAddress, &PeerInfo)) -> bool, 

Filter peers with according filter

fn peers(
    &self,
    network_id: NetworkId
) -> HashMap<PeerNetworkId, PeerInfo, RandomState>

Retrieve PeerInfo for the node