Struct 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 preprocess_certificate( &self, certificate: ConfirmedBlockCertificate, notifier: &impl Notifier, ) -> Result<(), LocalNodeError>

Preprocesses a block without executing it.

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

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

pub async fn stage_block_execution( &self, block: ProposedBlock, round: Option<u32>, published_blobs: Vec<Blob>, ) -> Result<(Block, 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 read_blob_states_from_storage( &self, blob_ids: &[BlobId], ) -> Result<Vec<BlobState>, LocalNodeError>

Reads blob states 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 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: ApplicationId, ) -> Result<ApplicationDescription, LocalNodeError>

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_outbox_heights( &self, chain_ids: impl IntoIterator<Item = &ChainId>, chain_worker_limit: usize, receiver_id: ChainId, ) -> Result<BTreeMap<ChainId, BlockHeight>, LocalNodeError>

Given a list of chain IDs, returns a map that assigns to each of them the next block height to schedule, i.e. the lowest block height for which we haven’t added the messages to receiver_id to the outbox 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.