Enum linera_core::chain_worker::ChainWorkerRequest

pub enum ChainWorkerRequest<Context>
where
    Context: Context + Clone + Send + Sync + 'static,
{
    ReadCertificate {
        height: BlockHeight,
        callback: Sender<Result<Option<ConfirmedBlockCertificate>, WorkerError>>,
    },
    FindBundleInInbox {
        inbox_id: Origin,
        certificate_hash: CryptoHash,
        height: BlockHeight,
        index: u32,
        callback: Sender<Result<Option<MessageBundle>, WorkerError>>,
    },
    GetChainStateView {
        callback: Sender<Result<OwnedRwLockReadGuard<ChainStateView<Context>>, WorkerError>>,
    },
    QueryApplication {
        query: Query,
        callback: Sender<Result<QueryOutcome, WorkerError>>,
    },
    DescribeApplication {
        application_id: UserApplicationId,
        callback: Sender<Result<UserApplicationDescription, WorkerError>>,
    },
    StageBlockExecution {
        block: ProposedBlock,
        round: Option<u32>,
        callback: Sender<Result<(ExecutedBlock, ChainInfoResponse), WorkerError>>,
    },
    ProcessTimeout {
        certificate: TimeoutCertificate,
        callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>,
    },
    HandleBlockProposal {
        proposal: BlockProposal,
        callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>,
    },
    ProcessValidatedBlock {
        certificate: ValidatedBlockCertificate,
        callback: Sender<Result<(ChainInfoResponse, NetworkActions, bool), WorkerError>>,
    },
    ProcessConfirmedBlock {
        certificate: ConfirmedBlockCertificate,
        notify_when_messages_are_delivered: Option<Sender<()>>,
        callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>,
    },
    ProcessCrossChainUpdate {
        origin: Origin,
        bundles: Vec<(Epoch, MessageBundle)>,
        callback: Sender<Result<Option<(BlockHeight, NetworkActions)>, WorkerError>>,
    },
    ConfirmUpdatedRecipient {
        latest_heights: Vec<(Target, BlockHeight)>,
        callback: Sender<Result<(), WorkerError>>,
    },
    HandleChainInfoQuery {
        query: ChainInfoQuery,
        callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>,
    },
    DownloadPendingBlob {
        blob_id: BlobId,
        callback: Sender<Result<Blob, WorkerError>>,
    },
    HandlePendingBlob {
        blob: Blob,
        callback: Sender<Result<ChainInfoResponse, WorkerError>>,
    },
    UpdateReceivedCertificateTrackers {
        new_trackers: BTreeMap<ValidatorPublicKey, u64>,
        callback: Sender<Result<(), WorkerError>>,
    },
}

A request for the ChainWorkerActor.

Variants

ReadCertificate

Reads the certificate for a requested BlockHeight.

Fields

height: BlockHeight

callback: Sender<Result<Option<ConfirmedBlockCertificate>, WorkerError>>

FindBundleInInbox

Search for a bundle in one of the chain’s inboxes.

Fields

inbox_id: Origin

certificate_hash: CryptoHash

height: BlockHeight

index: u32

callback: Sender<Result<Option<MessageBundle>, WorkerError>>

GetChainStateView

Request a read-only view of the ChainStateView.

Fields

callback: Sender<Result<OwnedRwLockReadGuard<ChainStateView<Context>>, WorkerError>>

QueryApplication

Query an application’s state.

Fields

query: Query

callback: Sender<Result<QueryOutcome, WorkerError>>

DescribeApplication

Describe an application.

Fields

application_id: UserApplicationId

callback: Sender<Result<UserApplicationDescription, WorkerError>>

StageBlockExecution

Execute a block but discard any changes to the chain state.

Fields

block: ProposedBlock

round: Option<u32>

callback: Sender<Result<(ExecutedBlock, ChainInfoResponse), WorkerError>>

ProcessTimeout

Process a leader timeout issued for this multi-owner chain.

Fields

certificate: TimeoutCertificate

callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>

HandleBlockProposal

Handle a proposal for the next block on this chain.

Fields

proposal: BlockProposal

callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>

ProcessValidatedBlock

Process a validated block issued for this multi-owner chain.

Fields

certificate: ValidatedBlockCertificate

callback: Sender<Result<(ChainInfoResponse, NetworkActions, bool), WorkerError>>

ProcessConfirmedBlock

Process a confirmed block (a commit).

Fields

certificate: ConfirmedBlockCertificate

notify_when_messages_are_delivered: Option<Sender<()>>

callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>

ProcessCrossChainUpdate

Process a cross-chain update.

Fields

origin: Origin

bundles: Vec<(Epoch, MessageBundle)>

callback: Sender<Result<Option<(BlockHeight, NetworkActions)>, WorkerError>>

ConfirmUpdatedRecipient

Handle cross-chain request to confirm that the recipient was updated.

Fields

latest_heights: Vec<(Target, BlockHeight)>

callback: Sender<Result<(), WorkerError>>

HandleChainInfoQuery

Handle a ChainInfoQuery.

Fields

query: ChainInfoQuery

callback: Sender<Result<(ChainInfoResponse, NetworkActions), WorkerError>>

DownloadPendingBlob

Get a blob if it belongs to the current locking block or pending proposal.

Fields

blob_id: BlobId

callback: Sender<Result<Blob, WorkerError>>

HandlePendingBlob

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

Fields

blob: Blob

callback: Sender<Result<ChainInfoResponse, WorkerError>>

UpdateReceivedCertificateTrackers

Update the received certificate trackers to at least the given values.

Fields

new_trackers: BTreeMap<ValidatorPublicKey, u64>

callback: Sender<Result<(), WorkerError>>

Implementations

impl<Context> ChainWorkerRequest<Context>

where Context: Context + Clone + Send + Sync + 'static,

pub fn send_error(self, error: WorkerError)

Responds to this request with an error.

Trait Implementations

impl<Context> Debug for ChainWorkerRequest<Context>

where Context: Context + Clone + Send + Sync + 'static,

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

Formats the value using the given formatter.