Trait fluvio_protocol_core::Decoder

pub trait Decoder: Sized + Default {
    fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error>
    where
        T: Buf;

    fn decode_from<T>(src: &mut T, version: Version) -> Result<Self, Error>
    where
        T: Buf,
        Self: Default,
    { ... }
}

Required methods

fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error> where
    T: Buf, 

Loading content...

Provided methods

fn decode_from<T>(src: &mut T, version: Version) -> Result<Self, Error> where
    T: Buf,
    Self: Default, 

decode Kafka compliant protocol values from buf

Loading content...

Implementations on Foreign Types

impl<M> Decoder for Vec<M> where
    M: Default + Decoder, 

fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error> where
    T: Buf, 

impl<M> Decoder for Option<M> where
    M: Default + Decoder, 

fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error> where
    T: Buf, 

impl<M> Decoder for PhantomData<M> where
    M: Default + Decoder, 

fn decode<T>(&mut self, _src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl<K, V> Decoder for BTreeMap<K, V> where
    K: Decoder + Ord,
    V: Decoder, 

fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for bool

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for i8

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for u8

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for i16

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for u16

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for i32

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for u32

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for i64

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

impl Decoder for String

fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
    T: Buf, 

Loading content...

Implementors

Loading content...