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<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 i32

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 u8

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 i8

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 i16

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 String

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 u16

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

impl Decoder for u32

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

Implementors

impl Decoder for ErrorCode

impl Decoder for Isolation

impl Decoder for SmartStreamError

impl Decoder for SmartStreamType

impl Decoder for BatchHeader

impl Decoder for AbortedTransaction

impl Decoder for FetchPartition

impl Decoder for FetchableTopic

impl Decoder for ForgottenTopic

impl Decoder for PartitionProduceResponse

impl Decoder for ProduceResponse

impl Decoder for TopicProduceResponse

impl Decoder for RecordData

impl Decoder for RecordHeader

impl Decoder for RecordSet

impl Decoder for SmartStreamInput

impl Decoder for SmartStreamOutput

impl Decoder for SmartStreamRuntimeError

impl Decoder for ReplicaKey

impl Decoder for ApiVersionKey

impl Decoder for ApiVersionsRequest

impl Decoder for ApiVersionsResponse

impl Decoder for PlatformVersion

impl Decoder for RequestHeader

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

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

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

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

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

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

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

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

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

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