Trait fluvio_protocol::Decoder[][src]

pub trait Decoder: Default {
    fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>
    where
        T: Buf
; fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>
    where
        Self: Default,
        T: Buf
, { ... } }

Required methods

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

Provided methods

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

decode Kafka compliant protocol values from buf

Implementations on Foreign Types

impl Decoder for bool[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for u32[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for u16[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl<M> Decoder for Option<M> where
    M: Default + Decoder
[src]

pub fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for u8[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

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

pub fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for i64[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl<M> Decoder for PhantomData<M> where
    M: Default + Decoder
[src]

pub fn decode<T>(&mut self, _src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for String[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for i16[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for i32[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl Decoder for i8[src]

pub fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error> where
    T: Buf
[src]

impl<M> Decoder for Vec<M, Global> where
    M: Default + Decoder
[src]

pub fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
    T: Buf
[src]

Implementors