Struct EncodedFrame 

pub struct EncodedFrame { /* private fields */ }

Immutable RocketMQ wire frame split into prefix, serialized header, and body segments.

Keeping the body in its existing Bytes allocation lets plaintext transports use vectored writes without first copying the complete frame into a second contiguous buffer. The frame’s exact Self::encoded_len is also available before transport staging or TLS aggregation.

Implementations

impl EncodedFrame

pub fn from_command(command: RemotingCommand) -> Result<Self>

Encodes a command into immutable wire segments.

Errors

Returns a serialization error when the command header cannot be encoded, the header exceeds RocketMQ’s 24-bit header-length field, or the complete frame exceeds its signed 32-bit length field.

pub fn encoded_len(&self) -> usize

Returns the complete encoded wire size, including the four-byte total-length prefix.

pub fn segments(&self) -> [&[u8]; 3]

Returns the immutable prefix, header, and body slices in wire order.

pub fn copy_to(&self, destination: &mut BytesMut)

Appends the wire frame to a caller-owned contiguous buffer.

This is intended for TLS record input and compatibility codecs. Plaintext transports should preserve Self::segments through to vectored socket writes.

pub fn into_bytes(self) -> Bytes

Materializes the complete frame as contiguous immutable bytes.

Prefer Self::segments when the destination accepts vectored writes.

Trait Implementations

impl Clone for EncodedFrame

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EncodedFrame

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

Formats the value using the given formatter.

impl Eq for EncodedFrame

impl PartialEq for EncodedFrame

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for EncodedFrame