Struct Message 

pub struct Message {
    pub id: MessageId,
    pub metadata: MessageMetadata,
    pub payload: MessagePayload,
}

Optimized message container with zero-copy support

Fields

id: MessageId

Message identifier

metadata: MessageMetadata

Message metadata

payload: MessagePayload

Message payload with zero-copy optimization

Implementations

impl Message

pub fn json(id: MessageId, value: impl Serialize) -> Result<Self>

Create a new message with JSON payload

Errors

Returns an error if the value cannot be serialized to JSON.

pub fn binary(id: MessageId, data: Bytes, format: BinaryFormat) -> Self

Create a new message with binary payload

pub fn text(id: MessageId, text: String) -> Self

Create a new message with text payload

pub fn empty(id: MessageId) -> Self

Create an empty message

pub const fn size(&self) -> usize

Get the message size in bytes

pub const fn is_empty(&self) -> bool

Check if the message is empty

pub fn serialize(&self, format: SerializationFormat) -> Result<Bytes>

Serialize message to bytes using the specified format

Errors

Returns an error if serialization fails for the specified format.

pub fn deserialize(bytes: Bytes) -> Result<Self>

Deserialize message from bytes with format auto-detection

Errors

Returns an error if format detection fails or deserialization fails.

pub fn deserialize_with_format( bytes: Bytes, format: SerializationFormat, ) -> Result<Self>

Deserialize message from bytes using specified format

pub fn parse_json<T>(&self) -> Result<T>

where T: for<'de> Deserialize<'de>,

Parse JSON payload to structured data

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.