[−]Struct fluvio::dataplane::core::codec::FluvioCodec
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
pub fn new() -> FluvioCodec
Trait Implementations
impl Debug for FluvioCodec
impl Decoder for FluvioCodec
type Item = BytesMut
The type of decoded frames.
type Error = Error
The type of unrecoverable frame decoding errors. Read more
pub fn decode(
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, <FluvioCodec as Decoder>::Error>
&mut self,
bytes: &mut BytesMut
) -> Result<Option<BytesMut>, <FluvioCodec as Decoder>::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 FluvioCodec
pub fn default() -> FluvioCodec
impl Encoder<Bytes> for FluvioCodec
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> Erased for T
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[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>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,