[−]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 i8
impl Decoder for u32
impl Decoder for u16
impl Decoder for String
impl Decoder for i32
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<M> Decoder for PhantomData<M> where
M: Default + Decoder,
M: Default + Decoder,
impl Decoder for bool
impl Decoder for i16
impl Decoder for i64
impl Decoder for u8
impl<K, V> Decoder for BTreeMap<K, V> where
K: Decoder + Ord,
V: Decoder,
Loading content...K: Decoder + Ord,
V: Decoder,
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,