Struct ProtocolMessage 

pub struct ProtocolMessage<N: NetworkPrimitives = EthNetworkPrimitives> {
    pub message_type: EthMessageID,
    pub message: EthMessage<N>,
}

An eth protocol message, containing a message ID and payload.

Fields

message_type: EthMessageID

The unique identifier representing the type of the Ethereum message.

message: EthMessage<N>

The content of the message, including specific data based on the message type.

Implementations

impl<N: NetworkPrimitives> ProtocolMessage<N>

pub fn decode_status( version: EthVersion, buf: &mut &[u8], ) -> Result<StatusMessage, MessageError>

Decode only a Status message from RLP bytes.

This is used during the eth handshake where only a Status message is a valid response. Returns an error if the message is not a Status message.

pub fn decode_message( version: EthVersion, buf: &mut &[u8], ) -> Result<Self, MessageError>

Create a new ProtocolMessage from a message type and message rlp bytes.

This will enforce decoding according to the given EthVersion of the connection.

pub fn decode_message_with_tx_memory_budget( version: EthVersion, buf: &mut &[u8], tx_memory_budget: usize, ) -> Result<Self, MessageError>

Like Self::decode_message, but caps the cumulative in-memory size of decoded transactions in Transactions and PooledTransactions messages. Once exceeded, remaining transactions are silently dropped.

Use TX_MEMORY_BUDGET_MULTIPLIER to derive a reasonable default.

Trait Implementations

impl<N: Clone + NetworkPrimitives> Clone for ProtocolMessage<N>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<N: Debug + NetworkPrimitives> Debug for ProtocolMessage<N>

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

Formats the value using the given formatter.

impl<'de, N: NetworkPrimitives> Deserialize<'de> for ProtocolMessage<N>

where EthMessage<N>: Serialize + DeserializeOwned,

Available on crate feature serde only.

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<N: NetworkPrimitives> Encodable for ProtocolMessage<N>

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

Encodes the protocol message into bytes. The message type is encoded as a single byte and prepended to the message.

fn length(&self) -> usize

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

impl<N: Eq + NetworkPrimitives> Eq for ProtocolMessage<N>

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

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

Converts to this type from the input type.

impl<N: PartialEq + NetworkPrimitives> PartialEq for ProtocolMessage<N>

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

Equality operator ==.

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

Inequality operator !=.

impl<N: NetworkPrimitives> Serialize for ProtocolMessage<N>

where EthMessage<N>: Serialize + DeserializeOwned,

Available on crate feature serde only.

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<N: PartialEq + NetworkPrimitives> StructuralPartialEq for ProtocolMessage<N>

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: 144 bytes