Enum EthMessage

pub enum EthMessage<N = EthNetworkPrimitives>
where
    N: NetworkPrimitives,
{
    Status(Status),
    NewBlockHashes(NewBlockHashes),
    NewBlock(Box<NewBlock<<N as NetworkPrimitives>::Block>>),
    Transactions(Transactions<<N as NetworkPrimitives>::BroadcastedTransaction>),
    NewPooledTransactionHashes66(NewPooledTransactionHashes66),
    NewPooledTransactionHashes68(NewPooledTransactionHashes68),
    GetBlockHeaders(RequestPair<GetBlockHeaders>),
    BlockHeaders(RequestPair<BlockHeaders<<N as NetworkPrimitives>::BlockHeader>>),
    GetBlockBodies(RequestPair<GetBlockBodies>),
    BlockBodies(RequestPair<BlockBodies<<N as NetworkPrimitives>::BlockBody>>),
    GetPooledTransactions(RequestPair<GetPooledTransactions>),
    PooledTransactions(RequestPair<PooledTransactions<<N as NetworkPrimitives>::PooledTransaction>>),
    GetNodeData(RequestPair<GetNodeData>),
    NodeData(RequestPair<NodeData>),
    GetReceipts(RequestPair<GetReceipts>),
    Receipts(RequestPair<Receipts<<N as NetworkPrimitives>::Receipt>>),
}

Available on crate feature network only.

Represents a message in the eth wire protocol, versions 66, 67 and 68.

The ethereum wire protocol is a set of messages that are broadcast to the network in two styles:

• A request message sent by a peer (such as GetPooledTransactions), and an associated response message (such as PooledTransactions).
• A message that is broadcast to the network, without a corresponding request.

The newer eth/66 is an efficiency upgrade on top of eth/65, introducing a request id to correlate request-response message pairs. This allows for request multiplexing.

The eth/67 is based on eth/66 but only removes two messages, GetNodeData and NodeData.

The eth/68 changes only NewPooledTransactionHashes to include types and sized. For it, NewPooledTransactionHashes is renamed as NewPooledTransactionHashes66 and NewPooledTransactionHashes68 is defined.

Variants

Status(Status)

Represents a Status message required for the protocol handshake.

NewBlockHashes(NewBlockHashes)

Represents a NewBlockHashes message broadcast to the network.

NewBlock(Box<NewBlock<<N as NetworkPrimitives>::Block>>)

Represents a NewBlock message broadcast to the network.

Transactions(Transactions<<N as NetworkPrimitives>::BroadcastedTransaction>)

Represents a Transactions message broadcast to the network.

NewPooledTransactionHashes66(NewPooledTransactionHashes66)

Represents a NewPooledTransactionHashes message for eth/66 version.

NewPooledTransactionHashes68(NewPooledTransactionHashes68)

Represents a NewPooledTransactionHashes message for eth/68 version.

GetBlockHeaders(RequestPair<GetBlockHeaders>)

Represents a GetBlockHeaders request-response pair.

BlockHeaders(RequestPair<BlockHeaders<<N as NetworkPrimitives>::BlockHeader>>)

Represents a BlockHeaders request-response pair.

GetBlockBodies(RequestPair<GetBlockBodies>)

Represents a GetBlockBodies request-response pair.

BlockBodies(RequestPair<BlockBodies<<N as NetworkPrimitives>::BlockBody>>)

Represents a BlockBodies request-response pair.

GetPooledTransactions(RequestPair<GetPooledTransactions>)

Represents a GetPooledTransactions request-response pair.

PooledTransactions(RequestPair<PooledTransactions<<N as NetworkPrimitives>::PooledTransaction>>)

Represents a PooledTransactions request-response pair.

GetNodeData(RequestPair<GetNodeData>)

Represents a GetNodeData request-response pair.

NodeData(RequestPair<NodeData>)

Represents a NodeData request-response pair.

GetReceipts(RequestPair<GetReceipts>)

Represents a GetReceipts request-response pair.

Receipts(RequestPair<Receipts<<N as NetworkPrimitives>::Receipt>>)

Represents a Receipts request-response pair.

Implementations

impl<N> EthMessage<N>

where N: NetworkPrimitives,

pub const fn message_id(&self) -> EthMessageID

Returns the message’s ID.

pub const fn is_request(&self) -> bool

Returns true if the message variant is a request.

pub const fn is_response(&self) -> bool

Returns true if the message variant is a response to a request.

Trait Implementations

impl<N> Clone for EthMessage<N>

where N: Clone + NetworkPrimitives, <N as NetworkPrimitives>::Block: Clone, <N as NetworkPrimitives>::BroadcastedTransaction: Clone, <N as NetworkPrimitives>::BlockHeader: Clone, <N as NetworkPrimitives>::BlockBody: Clone, <N as NetworkPrimitives>::PooledTransaction: Clone, <N as NetworkPrimitives>::Receipt: Clone,

fn clone(&self) -> EthMessage<N>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<N> Debug for EthMessage<N>

where N: Debug + NetworkPrimitives, <N as NetworkPrimitives>::Block: Debug, <N as NetworkPrimitives>::BroadcastedTransaction: Debug, <N as NetworkPrimitives>::BlockHeader: Debug, <N as NetworkPrimitives>::BlockBody: Debug, <N as NetworkPrimitives>::PooledTransaction: Debug, <N as NetworkPrimitives>::Receipt: Debug,

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

Formats the value using the given formatter.

impl<'de, N> Deserialize<'de> for EthMessage<N>

where N: NetworkPrimitives, <N as NetworkPrimitives>::Block: Serialize + DeserializeOwned, <N as NetworkPrimitives>::BroadcastedTransaction: Serialize + DeserializeOwned, <N as NetworkPrimitives>::BlockHeader: Serialize + DeserializeOwned, <N as NetworkPrimitives>::BlockBody: Serialize + DeserializeOwned, <N as NetworkPrimitives>::PooledTransaction: Serialize + DeserializeOwned, <N as NetworkPrimitives>::Receipt: Serialize + DeserializeOwned,

fn deserialize<__D>( __deserializer: __D, ) -> Result<EthMessage<N>, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<N> Encodable for EthMessage<N>

where N: NetworkPrimitives,

fn encode(&self, out: &mut dyn BufMut)

Encodes the type into the out buffer.

fn length(&self) -> usize

Returns the length of the encoding of this type in bytes.

impl<N> From<EthMessage<N>> for ProtocolMessage<N>

where N: NetworkPrimitives,

fn from(message: EthMessage<N>) -> ProtocolMessage<N>

Converts to this type from the input type.

impl<N> From<NewPooledTransactionHashes> for EthMessage<N>

where N: NetworkPrimitives,

fn from(value: NewPooledTransactionHashes) -> EthMessage<N>

Converts to this type from the input type.

impl<N> PartialEq for EthMessage<N>

where N: PartialEq + NetworkPrimitives, <N as NetworkPrimitives>::Block: PartialEq, <N as NetworkPrimitives>::BroadcastedTransaction: PartialEq, <N as NetworkPrimitives>::BlockHeader: PartialEq, <N as NetworkPrimitives>::BlockBody: PartialEq, <N as NetworkPrimitives>::PooledTransaction: PartialEq, <N as NetworkPrimitives>::Receipt: PartialEq,

fn eq(&self, other: &EthMessage<N>) -> bool

Tests for self and other values to be equal, and is used by ==.

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

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

impl<N> Serialize for EthMessage<N>

where N: NetworkPrimitives, <N as NetworkPrimitives>::Block: Serialize + DeserializeOwned, <N as NetworkPrimitives>::BroadcastedTransaction: Serialize + DeserializeOwned, <N as NetworkPrimitives>::BlockHeader: Serialize + DeserializeOwned, <N as NetworkPrimitives>::BlockBody: Serialize + DeserializeOwned, <N as NetworkPrimitives>::PooledTransaction: Serialize + DeserializeOwned, <N as NetworkPrimitives>::Receipt: Serialize + DeserializeOwned,

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<N> Sink<EthMessage<N>> for EthRlpxConnection<N>

where N: NetworkPrimitives,

type Error = EthStreamError

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut EthRlpxConnection<N>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut EthRlpxConnection<N>>, item: EthMessage<N>, ) -> Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut EthRlpxConnection<N>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut EthRlpxConnection<N>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <EthRlpxConnection<N> as Sink<EthMessage<N>>>::Error>>

Flush any remaining output and close this sink, if necessary.

impl<N> Eq for EthMessage<N>

where N: Eq + NetworkPrimitives, <N as NetworkPrimitives>::Block: Eq, <N as NetworkPrimitives>::BroadcastedTransaction: Eq, <N as NetworkPrimitives>::BlockHeader: Eq, <N as NetworkPrimitives>::BlockBody: Eq, <N as NetworkPrimitives>::PooledTransaction: Eq, <N as NetworkPrimitives>::Receipt: Eq,

impl<N> StructuralPartialEq for EthMessage<N>

where N: NetworkPrimitives,

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 136 bytes

Size for each variant:

• Status: 136 bytes
• NewBlockHashes: 32 bytes
• NewBlock: 16 bytes
• Transactions: 32 bytes
• NewPooledTransactionHashes66: 32 bytes
• NewPooledTransactionHashes68: 80 bytes
• GetBlockHeaders: 72 bytes
• BlockHeaders: 40 bytes
• GetBlockBodies: 40 bytes
• BlockBodies: 40 bytes
• GetPooledTransactions: 40 bytes
• PooledTransactions: 40 bytes
• GetNodeData: 40 bytes
• NodeData: 40 bytes
• GetReceipts: 40 bytes
• Receipts: 40 bytes