Struct ProtocolCodec 

pub struct ProtocolCodec { /* private fields */ }

Protocol codec for framing messages

Implementations

impl ProtocolCodec

pub fn new() -> Self

Create a new codec

pub fn with_max_size(max_message_size: usize) -> Self

Create codec with custom max message size

pub fn decode_startup( &self, src: &mut BytesMut, ) -> Result<Option<StartupMessage>>

Decode a startup message (no tag byte)

pub fn decode_message(&self, src: &mut BytesMut) -> Result<Option<Message>>

Decode a regular message (with tag byte)

pub fn encode_message(&self, msg: &Message) -> BytesMut

Encode a message

Trait Implementations

impl Default for ProtocolCodec

fn default() -> Self

Returns the “default value” for a type.