pub enum RpcMessage {
Show 33 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>),
DownloadCertificatesByHeights(ChainId, Vec<BlockHeight>),
BlobLastUsedBy(Box<BlobId>),
MissingBlobIds(Vec<BlobId>),
VersionInfoQuery,
NetworkDescriptionQuery,
Vote(Box<LiteVote>),
ChainInfoResponse(Box<ChainInfoResponse>),
Error(Box<NodeError>),
VersionInfoResponse(Box<VersionInfo>),
NetworkDescriptionResponse(Box<NetworkDescription>),
UploadBlobResponse(Box<BlobId>),
DownloadBlobResponse(Box<BlobContent>),
DownloadPendingBlobResponse(Box<BlobContent>),
DownloadConfirmedBlockResponse(Box<ConfirmedBlock>),
DownloadCertificatesResponse(Vec<ConfirmedBlockCertificate>),
DownloadCertificatesByHeightsResponse(Vec<ConfirmedBlockCertificate>),
BlobLastUsedByResponse(Box<CryptoHash>),
MissingBlobIdsResponse(Vec<BlobId>),
CrossChainRequest(Box<CrossChainRequest>),
BlobLastUsedByCertificate(Box<BlobId>),
BlobLastUsedByCertificateResponse(Box<ConfirmedBlockCertificate>),
}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>)
DownloadCertificatesByHeights(ChainId, Vec<BlockHeight>)
BlobLastUsedBy(Box<BlobId>)
MissingBlobIds(Vec<BlobId>)
VersionInfoQuery
NetworkDescriptionQuery
Vote(Box<LiteVote>)
ChainInfoResponse(Box<ChainInfoResponse>)
Error(Box<NodeError>)
VersionInfoResponse(Box<VersionInfo>)
NetworkDescriptionResponse(Box<NetworkDescription>)
UploadBlobResponse(Box<BlobId>)
DownloadBlobResponse(Box<BlobContent>)
DownloadPendingBlobResponse(Box<BlobContent>)
DownloadConfirmedBlockResponse(Box<ConfirmedBlock>)
DownloadCertificatesResponse(Vec<ConfirmedBlockCertificate>)
DownloadCertificatesByHeightsResponse(Vec<ConfirmedBlockCertificate>)
BlobLastUsedByResponse(Box<CryptoHash>)
MissingBlobIdsResponse(Vec<BlobId>)
CrossChainRequest(Box<CrossChainRequest>)
BlobLastUsedByCertificate(Box<BlobId>)
BlobLastUsedByCertificateResponse(Box<ConfirmedBlockCertificate>)
Implementations§
Source§impl RpcMessage
impl RpcMessage
Sourcepub fn target_chain_id(&self) -> Option<ChainId>
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.
Sourcepub fn is_local_message(&self) -> bool
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§
Source§impl Clone for RpcMessage
impl Clone for RpcMessage
Source§fn clone(&self) -> RpcMessage
fn clone(&self) -> RpcMessage
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for RpcMessage
impl Debug for RpcMessage
Source§impl<'de> Deserialize<'de> for RpcMessage
impl<'de> Deserialize<'de> for RpcMessage
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl From<NodeError> for RpcMessage
impl From<NodeError> for RpcMessage
Source§impl Serialize for RpcMessage
impl Serialize for RpcMessage
Source§impl TryFrom<RpcMessage> for BlobContent
impl TryFrom<RpcMessage> for BlobContent
Source§impl TryFrom<RpcMessage> for BlobId
impl TryFrom<RpcMessage> for BlobId
Source§impl TryFrom<RpcMessage> for ChainInfoResponse
impl TryFrom<RpcMessage> for ChainInfoResponse
Source§impl TryFrom<RpcMessage> for ConfirmedBlock
impl TryFrom<RpcMessage> for ConfirmedBlock
Source§impl TryFrom<RpcMessage> for CryptoHash
impl TryFrom<RpcMessage> for CryptoHash
Source§impl TryFrom<RpcMessage> for NetworkDescription
impl TryFrom<RpcMessage> for NetworkDescription
Source§impl TryFrom<RpcMessage> for Vec<ConfirmedBlockCertificate>
impl TryFrom<RpcMessage> for Vec<ConfirmedBlockCertificate>
Source§impl TryFrom<RpcMessage> for VersionInfo
impl TryFrom<RpcMessage> for VersionInfo
Auto Trait Implementations§
impl Freeze for RpcMessage
impl RefUnwindSafe for RpcMessage
impl Send for RpcMessage
impl Sync for RpcMessage
impl Unpin for RpcMessage
impl UnsafeUnpin for RpcMessage
impl UnwindSafe for RpcMessage
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
impl<Choices> CoproductSubsetter<CNil, HNil> for Choices
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<M, I> RuntimeMemory<&mut I> for Mwhere
M: RuntimeMemory<I>,
impl<M, I> RuntimeMemory<&mut I> for Mwhere
M: RuntimeMemory<I>,
Source§fn read<'instance>(
&self,
instance: &'instance &mut I,
location: GuestPointer,
length: u32,
) -> Result<Cow<'instance, [u8]>, RuntimeError>
fn read<'instance>( &self, instance: &'instance &mut I, location: GuestPointer, length: u32, ) -> Result<Cow<'instance, [u8]>, RuntimeError>
Reads length bytes from memory from the provided location.
Source§fn write(
&mut self,
instance: &mut &mut I,
location: GuestPointer,
bytes: &[u8],
) -> Result<(), RuntimeError>
fn write( &mut self, instance: &mut &mut I, location: GuestPointer, bytes: &[u8], ) -> Result<(), RuntimeError>
Writes the bytes to memory at the provided location.