Struct fluvio::dataplane::codec::FluvioCodec
source · pub struct FluvioCodec {}
Expand description
Implement Fluvio Encoding First 4 bytes are size of the message. Then total buffer = 4 + message content
Implementations§
source§impl FluvioCodec
impl FluvioCodec
pub fn new() -> FluvioCodec
Trait Implementations§
source§impl Debug for FluvioCodec
impl Debug for FluvioCodec
source§impl Decoder for FluvioCodec
impl Decoder for FluvioCodec
source§fn decode(
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, <FluvioCodec as Decoder>::Error>
fn decode( &mut self, bytes: &mut BytesMut ) -> Result<Option<BytesMut>, <FluvioCodec as Decoder>::Error>
Attempts to decode a frame from the provided buffer of bytes. Read more
source§impl Default for FluvioCodec
impl Default for FluvioCodec
source§fn default() -> FluvioCodec
fn default() -> FluvioCodec
Returns the “default value” for a type. Read more
source§impl Encoder<Bytes> for FluvioCodec
impl Encoder<Bytes> for FluvioCodec
Implement encoder for Fluvio Codec This is straight pass thru, actual encoding is done file slice
Auto Trait Implementations§
impl Freeze for FluvioCodec
impl RefUnwindSafe for FluvioCodec
impl Send for FluvioCodec
impl Sync for FluvioCodec
impl Unpin for FluvioCodec
impl UnwindSafe for FluvioCodec
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more