[−][src]Struct kf_protocol_transport::KfCodec
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 KfCodec
[src]
Trait Implementations
impl Debug for KfCodec
[src]
impl Decoder for KfCodec
[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>
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>
fn framed<T>(self, io: T) -> Framed<T, Self> where
T: AsyncRead + AsyncWrite,
[src]
T: AsyncRead + AsyncWrite,
impl Default for KfCodec
[src]
impl Encoder<Bytes> for KfCodec
[src]
Implement encoder for Kafka Codec We don't write buffer length because of file slice. The buffer length is encoded in the
Auto Trait Implementations
impl RefUnwindSafe for KfCodec
impl Send for KfCodec
impl Sync for KfCodec
impl Unpin for KfCodec
impl UnwindSafe for KfCodec
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,
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.
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>,