Struct Message 

pub struct Message {
    pub v: u8,
    pub t: MessageType,
    pub id: u32,
    pub flags: u8,
    pub p: Vec<u8>,
}

The message envelope sent over the wire.

Each message contains a version, type, correlation ID, flags, and a CBOR payload.

Wire format: [len: u32 BE][id: u32 BE][flags: u8][CBOR(v, t, p)]

The id and flags fields live in the binary frame header (outside CBOR) so that relay intermediaries can route frames without CBOR parsing.

Fields

v: u8

Protocol version.

t: MessageType

Message type.

id: u32

Correlation ID used to associate requests with responses and to identify exec sessions.

Serialized in the binary frame header, not in CBOR.

flags: u8

Frame flags computed from the message type.

Serialized in the binary frame header, not in CBOR.

p: Vec<u8>

The CBOR-encoded payload bytes.

Implementations

impl Message

pub fn new(t: MessageType, id: u32, p: Vec<u8>) -> Self

Creates a new message with the current protocol version and raw payload bytes.

pub fn with_payload<T: Serialize>( t: MessageType, id: u32, payload: &T, ) -> ProtocolResult<Self>

Creates a new message by serializing the given payload to CBOR.

pub fn payload<T: DeserializeOwned>(&self) -> ProtocolResult<T>

Deserializes the payload bytes into the given type.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Message

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Message

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

where __S: Serializer,

Serialize this value into the given Serde serializer.