Enum Client 

pub enum Client {
    Grpc(Box<GrpcClient>),
}

A client for communicating with a validator over one of the supported networks.

Variants

Grpc(Box<GrpcClient>)

A client using the gRPC network.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate 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 ValidatorNode for Client

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

The type of stream of notifications returned when subscribing.

fn address(&self) -> String

Returns the address of this validator node.

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_timeout_certificate( &self, certificate: TimeoutCertificate, ) -> Result<ChainInfoResponse, NodeError>

Processes a timeout certificate.

async fn handle_confirmed_certificate( &self, certificate: CacheArc<ConfirmedBlockCertificate>, delivery: CrossChainMessageDelivery, ) -> Result<ChainInfoResponse, NodeError>

Processes a confirmed certificate.

async fn handle_validated_certificate( &self, certificate: ValidatedBlockCertificate, ) -> Result<ChainInfoResponse, NodeError>

Processes a validated 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_network_description(&self) -> Result<NetworkDescription, NodeError>

Gets the network’s description.

async fn upload_blob(&self, content: BlobContent) -> Result<BlobId, NodeError>

Uploads a blob. Returns an error if the validator has not seen a certificate using this blob.

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

Downloads a blob. Returns an error if the validator does not have the blob.

async fn download_blobs( &self, blob_ids: Vec<BlobId>, ) -> Result<BlobStream, NodeError>

Downloads a batch of blobs as a stream. The stream yields one blob per requested id, in order. On mid-stream errors, the caller can retry the remaining blob ids against another validator.

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

Downloads a blob that belongs to a pending proposal or the locking block on a chain.

async fn handle_pending_blob( &self, chain_id: ChainId, blob: BlobContent, ) -> Result<ChainInfoResponse, NodeError>

Handles a blob that belongs to a pending proposal or validated block certificate.

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

Downloads the confirmed block certificate with the given hash.

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

Requests a batch of certificates from the validator.

async fn download_certificates_by_heights( &self, chain_id: ChainId, heights: Vec<BlockHeight>, ) -> Result<Vec<ConfirmedBlockCertificate>, NodeError>

Requests a batch of certificates from a specific chain by heights.

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

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

async fn missing_blob_ids( &self, blob_ids: Vec<BlobId>, ) -> Result<Vec<BlobId>, NodeError>

Returns the missing Blobs by their IDs.

async fn blob_last_used_by_certificate( &self, blob_id: BlobId, ) -> Result<ConfirmedBlockCertificate, NodeError>

Returns the certificate that last used the blob.

async fn previous_event_blocks( &self, chain_id: ChainId, stream_ids: Vec<StreamId>, ) -> Result<BTreeMap<StreamId, (BlockHeight, CryptoHash)>, NodeError>

Returns the previous event blocks for a chain’s streams.

fn upload_blobs( &self, blobs: Vec<Arc<Blob>>, ) -> impl Future<Output = Result<Vec<BlobId>, NodeError>> + Send

Uploads the blobs to the validator.