Struct fluvio_protocol_codec::FluvioCodec [−][src]
pub struct FluvioCodec {}
Expand description
Implement Fluvio Encoding First 4 bytes are size of the message. Then total buffer = 4 + message content
Implementations
impl FluvioCodec
[src]
impl FluvioCodec
[src]Trait Implementations
impl Debug for FluvioCodec
[src]
impl Debug for FluvioCodec
[src]impl Decoder for FluvioCodec
[src]
impl Decoder for FluvioCodec
[src]fn decode(
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, Self::Error>
[src]
fn decode(
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, Self::Error>
[src]Attempts to decode a frame from the provided buffer of bytes. Read more
impl Default for FluvioCodec
[src]
impl Default for FluvioCodec
[src]fn default() -> FluvioCodec
[src]
fn default() -> FluvioCodec
[src]Returns the “default value” for a type. Read more
impl<T: FluvioEncoder> Encoder<(T, i16)> for FluvioCodec
[src]
impl<T: FluvioEncoder> Encoder<(T, i16)> for FluvioCodec
[src]Implement encoder for Fluvio Codec
impl Encoder<Bytes> for FluvioCodec
[src]
impl Encoder<Bytes> for FluvioCodec
[src]Implement encoder for Fluvio Codec This is straight pass thru, actual encoding is done file slice