[−]Trait fluvio_dataplane_protocol::api::core::Decoder
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 i64
impl<M> Decoder for PhantomData<M> where
M: Default + Decoder,
M: Default + Decoder,
impl Decoder for String
impl Decoder for i8
impl<M> Decoder for Option<M> where
M: Default + Decoder,
M: Default + Decoder,
impl Decoder for i32
impl Decoder for bool
impl Decoder for u16
impl Decoder for i16
impl<M> Decoder for Vec<M, Global> where
M: Default + Decoder,
M: Default + Decoder,
impl<K, V> Decoder for BTreeMap<K, V> where
K: Decoder + Ord,
V: Decoder,
K: Decoder + Ord,
V: Decoder,
impl Decoder for u8
impl Decoder for u32
Loading content...Implementors
impl Decoder for ErrorCode
[src]
impl Decoder for Isolation
[src]
impl Decoder for RequestHeader
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]
pub fn decode<T>(&mut self, src: &mut T, _version: Version) -> Result<(), Error> where
T: Buf,
[src]
T: Buf,
impl Decoder for FileRecordSet
[src]
pub fn decode<T>(
&mut self,
_src: &mut T,
_version: Version
) -> Result<(), IoError> where
T: Buf,
[src]
&mut self,
_src: &mut T,
_version: Version
) -> Result<(), IoError> where
T: Buf,
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<(), IoError> where
T: Buf,
[src]
T: Buf,
Wrap the decoder for the string inside
impl<B> Decoder for Record<B> where
B: Decoder,
[src]
B: Decoder,
impl<R> Decoder for RequestMessage<R> where
R: Request,
R: Request,
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,