Struct GrpcClient

pub struct GrpcClient { /* private fields */ }

Implementations

impl GrpcClient

pub fn new( network: ValidatorPublicNetworkConfig, options: NodeOptions, ) -> Result<Self, GrpcError>

Trait Implementations

impl Clone for GrpcClient

fn clone(&self) -> GrpcClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl From<GrpcClient> for Client

fn from(client: GrpcClient) -> Self

Converts to this type from the input type.

impl MassClient for GrpcClient

fn send<'life0, 'async_trait>( &'life0 self, requests: Vec<RpcMessage>, max_in_flight: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<RpcMessage>, MassClientError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl ValidatorNode for GrpcClient

type NotificationStream = Pin<Box<dyn Stream<Item = Notification> + Send>>

async fn handle_block_proposal( &self, proposal: BlockProposal, ) -> Result<ChainInfoResponse, NodeError>

Proposes a new block.

async fn handle_lite_certificate( &self, certificate: LiteCertificate<'_>, delivery: CrossChainMessageDelivery, ) -> Result<ChainInfoResponse, NodeError>

Processes a certificate without a value.

async fn handle_certificate( &self, certificate: Certificate, blobs: Vec<Blob>, delivery: CrossChainMessageDelivery, ) -> Result<ChainInfoResponse, NodeError>

Processes a certificate.

async fn handle_chain_info_query( &self, query: ChainInfoQuery, ) -> Result<ChainInfoResponse, NodeError>

Handles information queries for this chain.

async fn subscribe( &self, chains: Vec<ChainId>, ) -> Result<Self::NotificationStream, NodeError>

Subscribes to receiving notifications for a collection of chains.

async fn get_version_info(&self) -> Result<VersionInfo, NodeError>

Gets the version info for this validator node.

async fn get_genesis_config_hash(&self) -> Result<CryptoHash, NodeError>

Gets the network’s genesis config hash.

async fn download_blob_content( &self, blob_id: BlobId, ) -> Result<BlobContent, NodeError>

async fn download_certificate_value( &self, hash: CryptoHash, ) -> Result<HashedCertificateValue, NodeError>

async fn download_certificate( &self, hash: CryptoHash, ) -> Result<Certificate, NodeError>

async fn download_certificates( &self, hashes: Vec<CryptoHash>, ) -> Result<Vec<Certificate>, NodeError>

Requests a batch of certificates from the validator.

async fn blob_last_used_by( &self, blob_id: BlobId, ) -> Result<CryptoHash, NodeError>

Returns the hash of the Certificate that last used a blob.