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 Decoder for bool
impl Decoder for u32
impl<K, V> Decoder for BTreeMap<K, V> where
K: Decoder + Ord,
V: Decoder,
K: Decoder + Ord,
V: Decoder,
impl<M> Decoder for PhantomData<M> where
M: Default + Decoder,
M: Default + Decoder,
impl Decoder for i32
impl Decoder for String
impl Decoder for i64
impl Decoder for u8
impl Decoder for i8
impl Decoder for i16
impl Decoder for u16
impl<M> Decoder for Vec<M, Global> where
M: Default + Decoder,
M: Default + Decoder,
impl<M> Decoder for Option<M> where
M: Default + Decoder,
M: Default + Decoder,
impl Decoder for Status
[src]
impl Decoder for AdminPublicApiKey
[src]
impl<C> Decoder for Message<C> where
C: Encoder + Decoder + Debug,
C: Encoder + Decoder + Debug,
impl Decoder for ReplicaMsgs
impl Decoder for MsgType
impl Decoder for SpuServerApiKey
[src]
impl<R> Decoder for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl Decoder for ReplicaOffsetUpdate
[src]
impl Decoder for ReplicaOffsetUpdateRequest
[src]
impl Decoder for UpdateOffsetsResponse
[src]
impl Decoder for SpuClientApiKey
[src]
impl Decoder for FetchOffsetPartition
[src]
impl Decoder for OffsetUpdate
[src]
impl Decoder for FetchOffsetPartitionResponse
[src]
impl Decoder for FetchOffsetsResponse
[src]
impl<R> Decoder for StreamFetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl Decoder for OffsetUpdateStatus
[src]
impl Decoder for UpdateOffsetsRequest
[src]
impl Decoder for FetchOffsetTopicResponse
[src]
impl Decoder for FetchOffsetTopic
[src]
impl Decoder for FetchOffsetsRequest
[src]
impl Decoder for ReplicaOffsetUpdateResponse
[src]
Loading content...Implementors
impl Decoder for AllCreatableSpec
[src]
impl Decoder for DeleteRequest
[src]
impl Decoder for ListRequest
[src]
impl Decoder for ListResponse
[src]
impl Decoder for WatchRequest
[src]
impl Decoder for WatchResponse
[src]
impl Decoder for PartitionResolution
impl Decoder for SpuGroupStatusResolution
impl Decoder for CustomSpu
impl Decoder for CustomSpuKey
impl Decoder for EncryptionEnum
impl Decoder for SpuStatusResolution
impl Decoder for SpuType
impl Decoder for TopicResolution
impl Decoder for TopicSpec
impl Decoder for ErrorCode
[src]
impl Decoder for Isolation
[src]
impl Decoder for CreateRequest
[src]
impl Decoder for PartitionSpec
impl Decoder for PartitionStatus
impl Decoder for Replica
impl Decoder for ReplicaLeader
impl Decoder for ReplicaStatus
impl Decoder for EnvVar
impl Decoder for ReplicationConfig
impl Decoder for SpuConfig
impl Decoder for SpuGroupSpec
impl Decoder for SpuGroupStatus
impl Decoder for StorageConfig
impl Decoder for CustomSpuSpec
impl Decoder for Endpoint
impl Decoder for IngressAddr
impl Decoder for IngressPort
impl Decoder for SpuSpec
impl Decoder for SpuStatus
impl Decoder for PartitionMap
impl Decoder for PartitionMaps
impl Decoder for TopicReplicaParam
impl Decoder for TopicStatus
impl Decoder for BatchHeader
[src]
impl Decoder for AbortedTransaction
[src]
impl Decoder for FetchPartition
[src]
impl Decoder for FetchableTopic
[src]
impl Decoder for ForgottenTopic
[src]
impl Decoder for PartitionProduceResponse
[src]
impl Decoder for ProduceResponse
[src]
impl Decoder for TopicProduceResponse
[src]
impl Decoder for DefaultAsyncBuffer
[src]
impl Decoder for FileRecordSet
[src]
impl Decoder for RecordHeader
[src]
impl Decoder for RecordSet
[src]
impl Decoder for ReplicaKey
[src]
impl Decoder for ApiVersionKey
[src]
impl Decoder for ApiVersionsRequest
[src]
impl Decoder for ApiVersionsResponse
[src]
impl Decoder for PlatformVersion
[src]
pub fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error> where
T: Buf,
[src]
T: Buf,
Wrap the decoder for the string inside
impl Decoder for RequestHeader
impl<B> Decoder for Record<B> where
B: Decoder,
[src]
B: Decoder,
impl<R> Decoder for Batch<R> where
R: BatchRecords,
[src]
R: BatchRecords,
impl<R> Decoder for FetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for FetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for FetchableTopicResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for PartitionProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for ProduceRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for TopicProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
impl<R> Decoder for RequestMessage<R> where
R: Request,
R: Request,
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,
[src]
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
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,
[src]
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,