Trait fluvio_dataplane_protocol::api::core::Encoder [−]
pub trait Encoder { fn write_size(&self, version: i16) -> usize; fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error>
where
T: BufMut; fn as_bytes(&self, version: i16) -> Result<Bytes, Error> { ... } }
Required methods
Provided methods
Implementations on Foreign Types
impl<M> Encoder for PhantomData<M> where
M: Encoder,
impl<M> Encoder for PhantomData<M> where
M: Encoder,
Implementors
impl Encoder for BatchHeader
[src]
impl Encoder for BatchHeader
[src]impl Encoder for AbortedTransaction
[src]
impl Encoder for AbortedTransaction
[src]impl Encoder for FetchPartition
[src]
impl Encoder for FetchPartition
[src]impl Encoder for FetchableTopic
[src]
impl Encoder for FetchableTopic
[src]impl Encoder for ForgottenTopic
[src]
impl Encoder for ForgottenTopic
[src]impl Encoder for PartitionProduceResponse
[src]
impl Encoder for PartitionProduceResponse
[src]impl Encoder for ProduceResponse
[src]
impl Encoder for ProduceResponse
[src]impl Encoder for TopicProduceResponse
[src]
impl Encoder for TopicProduceResponse
[src]impl Encoder for RecordData
[src]
impl Encoder for RecordData
[src]impl Encoder for RecordHeader
[src]
impl Encoder for RecordHeader
[src]impl Encoder for ReplicaKey
[src]
impl Encoder for ReplicaKey
[src]impl Encoder for ApiVersionKey
[src]
impl Encoder for ApiVersionKey
[src]impl Encoder for ApiVersionsRequest
[src]
impl Encoder for ApiVersionsRequest
[src]impl Encoder for ApiVersionsResponse
[src]
impl Encoder for ApiVersionsResponse
[src]impl Encoder for PlatformVersion
[src]
impl Encoder for PlatformVersion
[src]impl Encoder for RequestHeader
impl Encoder for RequestHeader
impl<P> Encoder for ResponseMessage<P> where
P: Encoder + Default,
impl<P> Encoder for ResponseMessage<P> where
P: Encoder + Default,
impl<R> Encoder for Batch<R> where
R: BatchRecords,
[src]
impl<R> Encoder for Batch<R> where
R: BatchRecords,
[src]impl<R> Encoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
impl<R> Encoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]