Trait fluvio_dataplane_protocol::api::core::Decoder

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, 

Provided methods

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

decode Kafka compliant protocol values from buf

Implementations on Foreign Types

impl Decoder for u32

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

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

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

impl Decoder for u8

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

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

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

impl Decoder for i8

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

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

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

impl Decoder for String

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

impl Decoder for i32

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

impl Decoder for bool

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

impl Decoder for i64

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

impl Decoder for i16

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

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

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

impl Decoder for u16

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

Implementors

impl Decoder for ErrorCode

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

impl Decoder for Isolation

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

impl Decoder for BatchHeader

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

impl Decoder for AbortedTransaction

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

impl Decoder for FetchPartition

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

impl Decoder for FetchableTopic

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

impl Decoder for ForgottenTopic

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

impl Decoder for PartitionProduceResponse

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

impl Decoder for ProduceResponse

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

impl Decoder for TopicProduceResponse

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

impl Decoder for RecordData

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

impl Decoder for RecordHeader

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

impl Decoder for RecordSet

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

impl Decoder for ReplicaKey

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

impl Decoder for ApiVersionKey

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

impl Decoder for ApiVersionsRequest

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

impl Decoder for ApiVersionsResponse

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

impl Decoder for PlatformVersion

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

Wrap the decoder for the string inside

impl Decoder for RequestHeader

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

impl<B> Decoder for Record<B> where
    B: Decoder, 

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

impl<R> Decoder for Batch<R> where
    R: BatchRecords, 

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

impl<R> Decoder for FetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for FetchResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for FetchableTopicResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for PartitionProduceData<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for ProduceRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for TopicProduceData<R> where
    R: Encoder + Decoder + Default + Debug, 

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

impl<R> Decoder for RequestMessage<R> where
    R: Request, 

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