Struct fluvio_protocol_codec::FluvioCodec [−][src]
Implement Kafka codec as in https://kafka.apache.org/protocol#The_Messages_ListOffsets First 4 bytes are size of the message. Then total buffer = 4 + message content
Implementations
impl FluvioCodec
[src]
Trait Implementations
impl Debug for FluvioCodec
[src]
impl Decoder for FluvioCodec
[src]
type Item = BytesMut
The type of decoded frames.
type Error = IoError
The type of unrecoverable frame decoding errors. Read more
fn decode(
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, Self::Error>
[src]
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, Self::Error>
pub fn decode_eof(
&mut self,
buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>
[src]
&mut self,
buf: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>
pub fn framed<T>(self, io: T) -> Framed<T, Self> where
T: AsyncRead + AsyncWrite,
[src]
T: AsyncRead + AsyncWrite,
impl Default for FluvioCodec
[src]
fn default() -> FluvioCodec
[src]
impl Encoder<Bytes> for FluvioCodec
[src]
Implement encoder for Kafka Codec This is straight pass thru, actual encoding is done file slice
Auto Trait Implementations
impl RefUnwindSafe for FluvioCodec
impl Send for FluvioCodec
impl Sync for FluvioCodec
impl Unpin for FluvioCodec
impl UnwindSafe for FluvioCodec
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,