Enum linera_rpc::RpcMessage

pub enum RpcMessage {
    BlockProposal(Box<BlockProposal>),
    TimeoutCertificate(Box<HandleTimeoutCertificateRequest>),
    ValidatedCertificate(Box<HandleValidatedCertificateRequest>),
    ConfirmedCertificate(Box<HandleConfirmedCertificateRequest>),
    LiteCertificate(Box<HandleLiteCertRequest<'static>>),
    ChainInfoQuery(Box<ChainInfoQuery>),
    UploadBlob(Box<BlobContent>),
    DownloadBlob(Box<BlobId>),
    DownloadPendingBlob(Box<(ChainId, BlobId)>),
    HandlePendingBlob(Box<(ChainId, BlobContent)>),
    DownloadConfirmedBlock(Box<CryptoHash>),
    DownloadCertificates(Vec<CryptoHash>),
    BlobLastUsedBy(Box<BlobId>),
    MissingBlobIds(Vec<BlobId>),
    VersionInfoQuery,
    GenesisConfigHashQuery,
    Vote(Box<LiteVote>),
    ChainInfoResponse(Box<ChainInfoResponse>),
    Error(Box<NodeError>),
    VersionInfoResponse(Box<VersionInfo>),
    GenesisConfigHashResponse(Box<CryptoHash>),
    UploadBlobResponse(Box<BlobId>),
    DownloadBlobResponse(Box<BlobContent>),
    DownloadPendingBlobResponse(Box<BlobContent>),
    DownloadConfirmedBlockResponse(Box<ConfirmedBlock>),
    DownloadCertificatesResponse(Vec<ConfirmedBlockCertificate>),
    BlobLastUsedByResponse(Box<CryptoHash>),
    MissingBlobIdsResponse(Vec<BlobId>),
    CrossChainRequest(Box<CrossChainRequest>),
}

Variants

BlockProposal(Box<BlockProposal>)

TimeoutCertificate(Box<HandleTimeoutCertificateRequest>)

ValidatedCertificate(Box<HandleValidatedCertificateRequest>)

ConfirmedCertificate(Box<HandleConfirmedCertificateRequest>)

LiteCertificate(Box<HandleLiteCertRequest<'static>>)

ChainInfoQuery(Box<ChainInfoQuery>)

UploadBlob(Box<BlobContent>)

DownloadBlob(Box<BlobId>)

DownloadPendingBlob(Box<(ChainId, BlobId)>)

HandlePendingBlob(Box<(ChainId, BlobContent)>)

DownloadConfirmedBlock(Box<CryptoHash>)

DownloadCertificates(Vec<CryptoHash>)

BlobLastUsedBy(Box<BlobId>)

MissingBlobIds(Vec<BlobId>)

VersionInfoQuery

GenesisConfigHashQuery

Vote(Box<LiteVote>)

ChainInfoResponse(Box<ChainInfoResponse>)

Error(Box<NodeError>)

VersionInfoResponse(Box<VersionInfo>)

GenesisConfigHashResponse(Box<CryptoHash>)

UploadBlobResponse(Box<BlobId>)

DownloadBlobResponse(Box<BlobContent>)

DownloadPendingBlobResponse(Box<BlobContent>)

DownloadConfirmedBlockResponse(Box<ConfirmedBlock>)

DownloadCertificatesResponse(Vec<ConfirmedBlockCertificate>)

BlobLastUsedByResponse(Box<CryptoHash>)

MissingBlobIdsResponse(Vec<BlobId>)

CrossChainRequest(Box<CrossChainRequest>)

Implementations

impl RpcMessage

pub fn target_chain_id(&self) -> Option<ChainId>

Obtains the ChainId of the chain targeted by this message, if there is one.

Only inbound messages have target chains.

pub fn is_local_message(&self) -> bool

Whether this message is “local” i.e. will be executed locally on the proxy or if it’ll be proxied to the server.

Trait Implementations

impl Clone for RpcMessage

fn clone(&self) -> RpcMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RpcMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RpcMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Encoder<RpcMessage> for Codec

type Error = Error

The type of encoding errors.

fn encode( &mut self, message: RpcMessage, buffer: &mut BytesMut, ) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.

impl From<NodeError> for RpcMessage

fn from(error: NodeError) -> Self

Converts to this type from the input type.

impl PartialEq for RpcMessage

fn eq(&self, other: &RpcMessage) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for RpcMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<RpcMessage> for BlobContent

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RpcMessage> for BlobId

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RpcMessage> for ChainInfoResponse

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RpcMessage> for ConfirmedBlock

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RpcMessage> for CryptoHash

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RpcMessage> for Vec<BlobId>

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RpcMessage> for Vec<ConfirmedBlockCertificate>

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RpcMessage> for VersionInfo

type Error = NodeError

The type returned in the event of a conversion error.

fn try_from(message: RpcMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl Eq for RpcMessage

impl StructuralPartialEq for RpcMessage