Trait fluvio_protocol::core::Decoder

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

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

Required Methods

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

where T: Buf,

Provided Methods

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

where T: Buf,

decode Fluvio compliant protocol values from buf

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl Decoder for bool

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

where T: Buf,

impl Decoder for f32

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

where T: Buf,

impl Decoder for f64

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 i16

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 i64

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 u16

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 u64

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,

impl Decoder for Duration

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<M> Decoder for Option<M>

where M: Decoder,

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

where T: Buf,

impl<M> Decoder for Vec<M>

where M: Decoder,

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

where T: Buf,

impl<M> Decoder for PhantomData<M>

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

where T: Buf,

Implementors

impl Decoder for ByteBuf