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

fn write_size(&self, version: i16) -> usize

size of this object in bytes

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error> where
    T: BufMut, 

encoding contents for buffer

Provided methods

fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

Implementations on Foreign Types

impl<'_, M> Encoder for &'_ M where
    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, 

impl<M> Encoder for Option<M> where
    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, 

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, 

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, 

impl<M> Encoder for PhantomData<M> where
    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, 

impl<M> Encoder for Vec<M, Global> where
    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, 

impl<K, V> Encoder for BTreeMap<K, V> where
    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, 

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, 

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, 

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, 

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, 

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, 

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, 

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, 

Implementors

impl Encoder for ErrorCode

impl Encoder for Isolation

impl Encoder for SmartStreamError

impl Encoder for SmartStreamType

impl Encoder for BatchHeader

impl Encoder for AbortedTransaction

impl Encoder for FetchPartition

impl Encoder for FetchableTopic

impl Encoder for ForgottenTopic

impl Encoder for PartitionProduceResponse

impl Encoder for ProduceResponse

impl Encoder for TopicProduceResponse

impl Encoder for RecordData

impl Encoder for RecordHeader

impl Encoder for RecordSet

impl Encoder for SmartStreamInput

impl Encoder for SmartStreamOutput

impl Encoder for SmartStreamRuntimeError

impl Encoder for ReplicaKey

impl Encoder for ApiVersionKey

impl Encoder for ApiVersionsRequest

impl Encoder for ApiVersionsResponse

impl Encoder for PlatformVersion

impl Encoder for RequestHeader

impl<B> Encoder for Record<B> where
    B: Encoder + Default, 

impl<P> Encoder for ResponseMessage<P> where
    P: Encoder + Default, 

impl<R> Encoder for Batch<R> where
    R: BatchRecords, 

impl<R> Encoder for FetchRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

impl<R> Encoder for FetchResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

impl<R> Encoder for FetchablePartitionResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

impl<R> Encoder for FetchableTopicResponse<R> where
    R: Encoder + Decoder + Default + Debug, 

impl<R> Encoder for PartitionProduceData<R> where
    R: Encoder + Decoder + Default + Debug, 

impl<R> Encoder for ProduceRequest<R> where
    R: Encoder + Decoder + Default + Debug, 

impl<R> Encoder for TopicProduceData<R> where
    R: Encoder + Decoder + Default + Debug, 

impl<R> Encoder for RequestMessage<R> where
    R: Request,