Trait fluvio::dataplane::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
Loading content...Provided methods
pub fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error> where
Self: Default,
T: Buf,
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,
impl<M> Decoder for PhantomData<M> where
M: Default + Decoder,
impl Decoder for AdminPublicApiKey
[src]
impl Decoder for AdminPublicApiKey
[src]impl Decoder for ReplicaMsgs
impl Decoder for ReplicaMsgs
impl Decoder for MsgType
impl Decoder for MsgType
impl Decoder for UpdateOffsetsResponse
[src]
impl Decoder for UpdateOffsetsResponse
[src]impl Decoder for FetchOffsetPartition
[src]
impl Decoder for FetchOffsetPartition
[src]impl Decoder for ReplicaOffsetUpdateRequest
[src]
impl Decoder for ReplicaOffsetUpdateRequest
[src]impl Decoder for FetchOffsetsRequest
[src]
impl Decoder for FetchOffsetsRequest
[src]impl Decoder for ReplicaOffsetUpdate
[src]
impl Decoder for ReplicaOffsetUpdate
[src]impl Decoder for FetchOffsetsResponse
[src]
impl Decoder for FetchOffsetsResponse
[src]impl Decoder for UpdateOffsetsRequest
[src]
impl Decoder for UpdateOffsetsRequest
[src]impl Decoder for FetchOffsetTopicResponse
[src]
impl Decoder for FetchOffsetTopicResponse
[src]impl Decoder for FetchOffsetTopic
[src]
impl Decoder for FetchOffsetTopic
[src]impl Decoder for OffsetUpdateStatus
[src]
impl Decoder for OffsetUpdateStatus
[src]impl Decoder for FetchOffsetPartitionResponse
[src]
impl Decoder for FetchOffsetPartitionResponse
[src]impl Decoder for SpuClientApiKey
[src]
impl Decoder for SpuClientApiKey
[src]impl Decoder for SpuServerApiKey
[src]
impl Decoder for SpuServerApiKey
[src]impl Decoder for OffsetUpdate
[src]
impl Decoder for OffsetUpdate
[src]impl Decoder for ReplicaOffsetUpdateResponse
[src]
impl Decoder for ReplicaOffsetUpdateResponse
[src]Implementors
impl Decoder for AllCreatableSpec
[src]
impl Decoder for AllCreatableSpec
[src]impl Decoder for DeleteRequest
[src]
impl Decoder for DeleteRequest
[src]impl Decoder for ListRequest
[src]
impl Decoder for ListRequest
[src]impl Decoder for ListResponse
[src]
impl Decoder for ListResponse
[src]impl Decoder for WatchRequest
[src]
impl Decoder for WatchRequest
[src]impl Decoder for WatchResponse
[src]
impl Decoder for WatchResponse
[src]impl Decoder for PartitionResolution
impl Decoder for PartitionResolution
impl Decoder for SpuGroupStatusResolution
impl Decoder for SpuGroupStatusResolution
impl Decoder for CustomSpuKey
impl Decoder for CustomSpuKey
impl Decoder for EncryptionEnum
impl Decoder for EncryptionEnum
impl Decoder for SpuStatusResolution
impl Decoder for SpuStatusResolution
impl Decoder for TopicResolution
impl Decoder for TopicResolution
impl Decoder for CreateRequest
[src]
impl Decoder for CreateRequest
[src]impl Decoder for PartitionSpec
impl Decoder for PartitionSpec
impl Decoder for PartitionStatus
impl Decoder for PartitionStatus
impl Decoder for ReplicaLeader
impl Decoder for ReplicaLeader
impl Decoder for ReplicaStatus
impl Decoder for ReplicaStatus
impl Decoder for ReplicationConfig
impl Decoder for ReplicationConfig
impl Decoder for SpuGroupSpec
impl Decoder for SpuGroupSpec
impl Decoder for SpuGroupStatus
impl Decoder for SpuGroupStatus
impl Decoder for StorageConfig
impl Decoder for StorageConfig
impl Decoder for CustomSpuSpec
impl Decoder for CustomSpuSpec
impl Decoder for IngressAddr
impl Decoder for IngressAddr
impl Decoder for IngressPort
impl Decoder for IngressPort
impl Decoder for PartitionMap
impl Decoder for PartitionMap
impl Decoder for PartitionMaps
impl Decoder for PartitionMaps
impl Decoder for TopicReplicaParam
impl Decoder for TopicReplicaParam
impl Decoder for TopicStatus
impl Decoder for TopicStatus
impl Decoder for BatchHeader
[src]
impl Decoder for BatchHeader
[src]impl Decoder for AbortedTransaction
[src]
impl Decoder for AbortedTransaction
[src]impl Decoder for FetchPartition
[src]
impl Decoder for FetchPartition
[src]impl Decoder for FetchableTopic
[src]
impl Decoder for FetchableTopic
[src]impl Decoder for ForgottenTopic
[src]
impl Decoder for ForgottenTopic
[src]impl Decoder for PartitionProduceResponse
[src]
impl Decoder for PartitionProduceResponse
[src]impl Decoder for ProduceResponse
[src]
impl Decoder for ProduceResponse
[src]impl Decoder for TopicProduceResponse
[src]
impl Decoder for TopicProduceResponse
[src]impl Decoder for DefaultAsyncBuffer
[src]
impl Decoder for DefaultAsyncBuffer
[src]impl Decoder for FileRecordSet
[src]
impl Decoder for FileRecordSet
[src]impl Decoder for RecordHeader
[src]
impl Decoder for RecordHeader
[src]impl Decoder for ReplicaKey
[src]
impl Decoder for ReplicaKey
[src]impl Decoder for ApiVersionKey
[src]
impl Decoder for ApiVersionKey
[src]impl Decoder for ApiVersionsRequest
[src]
impl Decoder for ApiVersionsRequest
[src]impl Decoder for ApiVersionsResponse
[src]
impl Decoder for ApiVersionsResponse
[src]impl Decoder for PlatformVersion
[src]
impl Decoder for PlatformVersion
[src]impl Decoder for RequestHeader
impl Decoder for RequestHeader
impl<R> Decoder for Batch<R> where
R: BatchRecords,
[src]
impl<R> Decoder for Batch<R> where
R: BatchRecords,
[src]impl<R> Decoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
impl<R> Decoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]impl<R> Decoder for RequestMessage<R> where
R: Request,
impl<R> Decoder for RequestMessage<R> where
R: Request,