Struct Codec 

pub struct Codec { /* private fields */ }

gRPC length-prefixed framing codec.

Handles the 5-byte gRPC frame header (1 byte compression flag + 4 byte big-endian length) and protobuf encode/decode with optional compression.

Implementations

impl Codec

pub fn new() -> Codec

pub fn from_headers(headers: &HeaderMap) -> Codec

pub fn set_limit(&mut self, limit: usize)

Set the maximum allowed size in bytes for a single gRPC message frame. Set to 0 for unlimited.

pub const fn limit(&self) -> usize

pub fn decode<T>(&self, src: &mut BytesMut) -> Result<Option<T>, ProtocolError>

where T: Message + Default,

Try to decode a complete gRPC message from src.

Consumes the frame bytes from src on success.

Returns:

• Ok(Some(message)) when a complete frame is available
• Ok(None) when more data is needed
• Err on protocol violations (size limit, decode error)

pub fn encode<T>( &self, msg: &T, dst: &mut BytesMut, ) -> Result<(), ProtocolError>

where T: Message,

Encode a protobuf message into gRPC length-prefixed framing.

Writes to dst: 1 byte compression flag + 4 byte big-endian length + payload. When compression is enabled and the compress feature is active, the payload is compressed and the flag byte is set to 1.