[−][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
Methods
impl KfCodec
[src]
Trait Implementations
impl Debug for KfCodec
[src]
impl Decoder for KfCodec
[src]
type Item = BytesMut
The type of items returned by decode
type Error = IoError
The type of decoding errors.
fn decode(
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, Self::Error>
[src]
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, Self::Error>
impl Default for KfCodec
[src]
impl Encoder 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>,