Trait fluvio::dataplane::core::api::core::Decoder

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

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

Required methods

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

Loading content...

Provided methods

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

decode Kafka compliant protocol values from buf

Loading content...

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

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 u32

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 u16

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

impl Decoder for Status

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

impl Decoder for AdminPublicApiKey

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

impl Decoder for ReplicaMsgs

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

impl Decoder for MsgType

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

impl<C> Decoder for Message<C> where
    C: Encoder + Decoder + Debug, 

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

impl Decoder for ReplicaOffsetUpdateResponse

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

impl Decoder for FetchOffsetTopicResponse

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

impl Decoder for OffsetUpdate

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

impl Decoder for RegisterSyncReplicaRequest

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

impl Decoder for FetchOffsetsResponse

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

impl Decoder for UpdateOffsetsResponse

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

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

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

impl Decoder for ReplicaOffsetUpdate

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

impl Decoder for RegisterSyncReplicaResponse

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

impl Decoder for FetchOffsetsRequest

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

impl Decoder for FetchOffsetPartition

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

impl Decoder for ReplicaOffsetUpdateRequest

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

impl Decoder for UpdateOffsetsRequest

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

impl Decoder for SpuClientApiKey

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

impl Decoder for SpuServerApiKey

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

impl Decoder for FetchOffsetPartitionResponse

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

impl Decoder for OffsetUpdateStatus

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

impl Decoder for FetchOffsetTopic

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

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

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

Loading content...

Implementors

impl Decoder for ErrorCode

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

impl Decoder for Isolation

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

impl Decoder for AllCreatableSpec

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

impl Decoder for DeleteRequest

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

impl Decoder for ListRequest

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

impl Decoder for ListResponse

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

impl Decoder for WatchRequest

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

impl Decoder for WatchResponse

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

impl Decoder for PartitionResolution

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

impl Decoder for SpuGroupStatusResolution

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

impl Decoder for CustomSpu

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

impl Decoder for CustomSpuKey

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

impl Decoder for EncryptionEnum

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

impl Decoder for SpuStatusResolution

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

impl Decoder for SpuType

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

impl Decoder for TopicResolution

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

impl Decoder for TopicSpec

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

impl Decoder for BatchHeader

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

impl Decoder for RequestHeader

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

impl Decoder for AbortedTransaction

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

impl Decoder for FetchPartition

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

impl Decoder for FetchableTopic

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

impl Decoder for ForgottenTopic

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

impl Decoder for PartitionProduceResponse

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

impl Decoder for ProduceResponse

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

impl Decoder for TopicProduceResponse

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

impl Decoder for DefaultAsyncBuffer

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

impl Decoder for FileRecordSet

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

impl Decoder for RecordHeader

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

impl Decoder for RecordSet

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

impl Decoder for ReplicaKey

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

impl Decoder for ApiVersionKey

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

impl Decoder for ApiVersionsRequest

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

impl Decoder for ApiVersionsResponse

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

impl Decoder for PlatformVersion

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

Wrap the decoder for the string inside

impl Decoder for CreateRequest

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

impl Decoder for PartitionSpec

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

impl Decoder for PartitionStatus

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

impl Decoder for Replica

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

impl Decoder for ReplicaLeader

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

impl Decoder for ReplicaStatus

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

impl Decoder for EnvVar

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

impl Decoder for ReplicationConfig

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

impl Decoder for SpuConfig

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

impl Decoder for SpuGroupSpec

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

impl Decoder for SpuGroupStatus

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

impl Decoder for StorageConfig

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

impl Decoder for CustomSpuSpec

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

impl Decoder for Endpoint

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

impl Decoder for IngressAddr

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

impl Decoder for IngressPort

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

impl Decoder for SpuSpec

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

impl Decoder for SpuStatus

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

impl Decoder for PartitionMap

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

impl Decoder for PartitionMaps

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

impl Decoder for TopicReplicaParam

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

impl Decoder for TopicStatus

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, 

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

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

pub fn decode<T>(&mut self, src: &mut T, version: i16) -> 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, 

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

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

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

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

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

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

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

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

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

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

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

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

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

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

impl<S> Decoder for Metadata<S> where
    S: Spec + Debug + Encoder + Decoder,
    <S as Spec>::Status: Debug,
    <S as Spec>::Status: Encoder,
    <S as Spec>::Status: Decoder, 

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

impl<S> Decoder for MetadataUpdate<S> where
    S: Spec + Debug + Encoder + Decoder,
    <S as Spec>::Status: Debug,
    <S as Spec>::Status: Encoder,
    <S as Spec>::Status: Decoder, 

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

Loading content...