Trait fluvio_dataplane_protocol::api::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 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 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<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<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 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 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 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<K, V> Encoder for BTreeMap<K, V> where
V: Encoder,
K: Encoder,
V: Encoder,
K: 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 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 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 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 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,
Implementors
impl Encoder for ErrorCode
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for Isolation
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> 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 BatchHeader
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for AbortedTransaction
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for FetchPartition
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for FetchableTopic
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for ForgottenTopic
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for PartitionProduceResponse
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for ProduceResponse
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for TopicProduceResponse
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for DefaultAsyncBuffer
[src]
fn write_size(&self, version: Version) -> usize
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for FileRecordSet
[src]
fn write_size(&self, _version: Version) -> usize
[src]
fn encode<T>(&self, _src: &mut T, _version: Version) -> Result<(), IoError> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for RecordHeader
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for RecordSet
[src]
fn write_size(&self, version: Version) -> usize
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl Encoder for ReplicaKey
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for ApiVersionKey
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for ApiVersionsRequest
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for ApiVersionsResponse
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl Encoder for PlatformVersion
[src]
fn write_size(&self, version: Version) -> usize
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), IoError> where
T: BufMut,
[src]
T: BufMut,
impl<B> Encoder for Record<B> where
B: Encoder + Default,
[src]
B: Encoder + Default,
fn write_size(&self, version: Version) -> usize
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> 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 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 Batch<R> where
R: BatchRecords,
[src]
R: BatchRecords,
fn write_size(&self, version: Version) -> usize
[src]
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
impl<R> Encoder for FetchRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl<R> Encoder for FetchResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl<R> Encoder for FetchablePartitionResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl<R> Encoder for FetchableTopicResponse<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl<R> Encoder for PartitionProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl<R> Encoder for ProduceRequest<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,
fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error> where
T: BufMut,
[src]
T: BufMut,
fn write_size(&self, version: Version) -> usize
[src]
impl<R> Encoder for TopicProduceData<R> where
R: Encoder + Decoder + Default + Debug,
[src]
R: Encoder + Decoder + Default + Debug,