Trait fluvio::dataplane::core::Encoder [−]
pub trait Encoder { pub fn write_size(&self, version: i16) -> usize; pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error>
where
T: BufMut; pub fn as_bytes(&self, version: i16) -> Result<Bytes, Error> { ... } }
Required methods
pub fn write_size(&self, version: i16) -> usize
size of this object in bytes
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
encoding contents for buffer
Provided methods
Loading content...Implementations on Foreign Types
impl<M> Encoder for PhantomData<M> where
M: Encoder,
impl<M> Encoder for PhantomData<M> where
M: Encoder,
impl Encoder for AdminPublicRequest
[src]
impl Encoder for AdminPublicRequest
[src]impl Encoder for AdminPublicApiKey
[src]
impl Encoder for AdminPublicApiKey
[src]impl Encoder for ReplicaMsgs
impl Encoder for ReplicaMsgs
impl Encoder for MsgType
impl Encoder for MsgType
impl Encoder for UpdateOffsetsResponse
[src]
impl Encoder for UpdateOffsetsResponse
[src]impl Encoder for ReplicaOffsetUpdateResponse
[src]
impl Encoder for ReplicaOffsetUpdateResponse
[src]impl Encoder for SpuClientApiKey
[src]
impl Encoder for SpuClientApiKey
[src]impl Encoder for ReplicaOffsetUpdate
[src]
impl Encoder for ReplicaOffsetUpdate
[src]impl Encoder for FetchOffsetTopic
[src]
impl Encoder for FetchOffsetTopic
[src]impl Encoder for FetchOffsetTopicResponse
[src]
impl Encoder for FetchOffsetTopicResponse
[src]impl Encoder for OffsetUpdate
[src]
impl Encoder for OffsetUpdate
[src]impl Encoder for SpuServerRequest
[src]
impl Encoder for SpuServerRequest
[src]impl Encoder for UpdateOffsetsRequest
[src]
impl Encoder for UpdateOffsetsRequest
[src]impl Encoder for FetchOffsetsResponse
[src]
impl Encoder for FetchOffsetsResponse
[src]impl Encoder for FetchOffsetPartition
[src]
impl Encoder for FetchOffsetPartition
[src]impl Encoder for FetchOffsetPartitionResponse
[src]
impl Encoder for FetchOffsetPartitionResponse
[src]impl Encoder for ReplicaOffsetUpdateRequest
[src]
impl Encoder for ReplicaOffsetUpdateRequest
[src]impl Encoder for FetchOffsetsRequest
[src]
impl Encoder for FetchOffsetsRequest
[src]impl Encoder for OffsetUpdateStatus
[src]
impl Encoder for OffsetUpdateStatus
[src]impl Encoder for SpuClientRequest
[src]
impl Encoder for SpuClientRequest
[src]impl Encoder for SpuServerApiKey
[src]
impl Encoder for SpuServerApiKey
[src]Implementors
impl Encoder for AllCreatableSpec
[src]
impl Encoder for AllCreatableSpec
[src]impl Encoder for DeleteRequest
[src]
impl Encoder for DeleteRequest
[src]impl Encoder for ListRequest
[src]
impl Encoder for ListRequest
[src]impl Encoder for ListResponse
[src]
impl Encoder for ListResponse
[src]impl Encoder for WatchRequest
[src]
impl Encoder for WatchRequest
[src]impl Encoder for WatchResponse
[src]
impl Encoder for WatchResponse
[src]impl Encoder for PartitionResolution
impl Encoder for PartitionResolution
impl Encoder for SpuGroupStatusResolution
impl Encoder for SpuGroupStatusResolution
impl Encoder for CustomSpuKey
impl Encoder for CustomSpuKey
impl Encoder for EncryptionEnum
impl Encoder for EncryptionEnum
impl Encoder for SpuStatusResolution
impl Encoder for SpuStatusResolution
impl Encoder for TopicResolution
impl Encoder for TopicResolution
impl Encoder for CreateRequest
[src]
impl Encoder for CreateRequest
[src]impl Encoder for PartitionSpec
impl Encoder for PartitionSpec
impl Encoder for PartitionStatus
impl Encoder for PartitionStatus
impl Encoder for ReplicaLeader
impl Encoder for ReplicaLeader
impl Encoder for ReplicaStatus
impl Encoder for ReplicaStatus
impl Encoder for ReplicationConfig
impl Encoder for ReplicationConfig
impl Encoder for SpuGroupSpec
impl Encoder for SpuGroupSpec
impl Encoder for SpuGroupStatus
impl Encoder for SpuGroupStatus
impl Encoder for StorageConfig
impl Encoder for StorageConfig
impl Encoder for CustomSpuSpec
impl Encoder for CustomSpuSpec
impl Encoder for IngressAddr
impl Encoder for IngressAddr
impl Encoder for IngressPort
impl Encoder for IngressPort
impl Encoder for PartitionMap
impl Encoder for PartitionMap
impl Encoder for PartitionMaps
impl Encoder for PartitionMaps
impl Encoder for TopicReplicaParam
impl Encoder for TopicReplicaParam
impl Encoder for TopicStatus
impl Encoder for TopicStatus
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 DefaultAsyncBuffer
[src]
impl Encoder for DefaultAsyncBuffer
[src]impl Encoder for FileRecordSet
[src]
impl Encoder for FileRecordSet
[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]impl<R> Encoder for RequestMessage<R> where
R: Request,
impl<R> Encoder for RequestMessage<R> where
R: Request,
impl<S> Encoder 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]
impl<S> Encoder 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]