[−]Trait fluvio::dataplane::core::Encoder
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<K, V> Encoder for BTreeMap<K, V> where
K: Encoder,
V: Encoder,
K: Encoder,
V: Encoder,
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl<M> Encoder for Option<M> where
M: Encoder,
M: Encoder,
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for String
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for u8
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl<M> Encoder for PhantomData<M> where
M: Encoder,
M: Encoder,
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, _dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl<M> Encoder for Vec<M, Global> where
M: Encoder,
M: Encoder,
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for i8
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for u16
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for bool
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for i64
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for i32
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for i16
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for u32
pub fn write_size(&self, _version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for Status
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for AdminPublicRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for AdminPublicApiKey
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for MsgType
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl<C> Encoder for Message<C> where
C: Encoder + Decoder + Debug,
C: Encoder + Decoder + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for ReplicaMsgs
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for ReplicaOffsetUpdateRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for SpuServerRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for RegisterSyncReplicaResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for ReplicaOffsetUpdate
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchOffsetPartitionResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for SpuClientApiKey
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchOffsetsRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchOffsetPartition
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for ReplicaOffsetUpdateResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for StreamFetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchOffsetTopic
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for SpuServerApiKey
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for StreamFetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchOffsetTopicResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchOffsetsResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for SpuClientRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for RegisterSyncReplicaRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
Implementors
impl Encoder for ErrorCode
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for Isolation
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for AllCreatableSpec
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for DeleteRequest
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for ListRequest
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for ListResponse
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for WatchRequest
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for WatchResponse
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for PartitionResolution
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuGroupStatusResolution
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for CustomSpu
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for CustomSpuKey
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for EncryptionEnum
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuStatusResolution
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuType
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for TopicResolution
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for TopicSpec
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl Encoder for BatchHeader
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for RequestHeader
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for AbortedTransaction
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchPartition
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for FetchableTopic
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for ForgottenTopic
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for PartitionProduceResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for ProduceResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for TopicProduceResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for DefaultAsyncBuffer
[src]
pub fn write_size(&self, _version: i16) -> usize
[src]
pub fn encode<T>(&self, src: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for FileRecordSet
[src]
pub fn write_size(&self, _version: i16) -> usize
[src]
pub fn encode<T>(&self, _src: &mut T, _version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for RecordHeader
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for RecordSet
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for ReplicaKey
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for ApiVersionKey
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for ApiVersionsRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for ApiVersionsResponse
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for PlatformVersion
[src]
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for CreateRequest
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl Encoder for PartitionSpec
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for PartitionStatus
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for Replica
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for ReplicaLeader
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for ReplicaStatus
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for EnvVar
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for ReplicationConfig
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuConfig
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuGroupSpec
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuGroupStatus
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for StorageConfig
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for CustomSpuSpec
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for Endpoint
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for IngressAddr
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for IngressPort
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuSpec
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for SpuStatus
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for PartitionMap
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for PartitionMaps
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for TopicReplicaParam
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl Encoder for TopicStatus
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
impl<B> Encoder for Record<B> where
B: Encoder + Default,
[src]
B: Encoder + Default,
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl<P> Encoder for ResponseMessage<P> where
P: Encoder + Default,
P: Encoder + Default,
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, out: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl<R> Encoder for Batch<R> where
R: BatchRecords,
[src]
R: BatchRecords,
pub fn write_size(&self, version: i16) -> usize
[src]
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl<R> Encoder for RequestMessage<R> where
R: Request,
R: Request,
pub fn write_size(&self, version: i16) -> usize
pub fn encode<T>(&self, out: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
T: BufMut,
impl<R> Encoder for FetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for FetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for FetchableTopicResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for PartitionProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for ProduceRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<R> Encoder for TopicProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[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]
S: Spec + Debug + Encoder + Decoder,
<S as Spec>::Status: Debug,
<S as Spec>::Status: Encoder,
<S as Spec>::Status: Decoder,
pub fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
pub fn write_size(&self, version: i16) -> usize
[src]
impl<S> Encoder 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,