Struct linera_core::local_node::LocalNodeClient

pub struct LocalNodeClient<S>
where
    S: Storage,
{ /* private fields */ }

A client to a local node.

Implementations

impl<S> LocalNodeClient<S>

where S: Storage + Clone + Send + Sync + 'static,

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

pub async fn handle_lite_certificate( &self, certificate: LiteCertificate<'_>, notifier: &impl Notifier, ) -> Result<ChainInfoResponse, LocalNodeError>

pub async fn handle_certificate<T>( &self, certificate: GenericCertificate<T>, notifier: &impl Notifier, ) -> Result<ChainInfoResponse, LocalNodeError>

where T: ProcessableCertificate,

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

impl<S> LocalNodeClient<S>

where S: Storage,

pub fn new(state: WorkerState<S>) -> Self

impl<S> LocalNodeClient<S>

where S: Storage + Clone + Send + Sync + 'static,

pub async fn stage_block_execution( &self, block: ProposedBlock, round: Option<u32>, ) -> Result<(ExecutedBlock, ChainInfoResponse), LocalNodeError>

pub async fn read_blobs_from_storage( &self, blob_ids: &[BlobId], ) -> Result<Option<Vec<Blob>>, LocalNodeError>

Reads blobs from storage.

pub async fn get_locking_blobs( &self, blob_ids: impl IntoIterator<Item = &BlobId>, chain_id: ChainId, ) -> Result<Option<Vec<Blob>>, LocalNodeError>

Looks for the specified blobs in the local chain manager’s locking blobs. Returns Ok(None) if any of the blobs is not found.

pub async fn get_pending_blobs( &self, blob_ids: &[BlobId], chain_id: ChainId, ) -> Result<Option<Vec<Blob>>, LocalNodeError>

Looks for the specified blobs in the local chain manager’s pending blobs. Returns Ok(None) if any of the blobs is not found.

pub async fn store_blobs(&self, blobs: &[Blob]) -> Result<(), LocalNodeError>

Writes the given blobs to storage if there is an appropriate blob state.

pub async fn handle_pending_blobs( &self, chain_id: ChainId, blobs: Vec<Blob>, ) -> Result<(), LocalNodeError>

pub async fn chain_state_view( &self, chain_id: ChainId, ) -> Result<OwnedRwLockReadGuard<ChainStateView<S::Context>>, LocalNodeError>

Returns a read-only view of the ChainStateView of a chain referenced by its ChainId.

The returned view holds a lock on the chain state, which prevents the local node from changing the state of that chain.

pub async fn query_application( &self, chain_id: ChainId, query: Query, ) -> Result<QueryOutcome, LocalNodeError>

pub async fn describe_application( &self, chain_id: ChainId, application_id: UserApplicationId, ) -> Result<UserApplicationDescription, LocalNodeError>

pub async fn certificate_for( &self, message_id: &MessageId, ) -> Result<ConfirmedBlockCertificate, LocalNodeError>

Obtains the certificate containing the specified message.

pub async fn retry_pending_cross_chain_requests( &self, sender_chain: ChainId, ) -> Result<(), LocalNodeError>

Handles any pending local cross-chain requests.

pub async fn next_block_heights( &self, chain_ids: impl IntoIterator<Item = &ChainId>, chain_worker_limit: usize, ) -> Result<BTreeMap<ChainId, BlockHeight>, LocalNodeError>

Given a list of chain IDs, returns a map that assigns to each of them the next block height, i.e. the lowest block height that we have not processed in the local node yet.

It makes at most chain_worker_limit requests to the local node in parallel.

pub async fn update_received_certificate_trackers( &self, chain_id: ChainId, new_trackers: BTreeMap<ValidatorPublicKey, u64>, ) -> Result<(), LocalNodeError>

Trait Implementations

impl<S> Clone for LocalNodeClient<S>

where S: Storage + Clone,

fn clone(&self) -> LocalNodeClient<S>

Returns a copy of the value.

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

Performs copy-assignment from source.