Trait fluvio_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

Loading content...

Provided methods

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

Loading content...

Implementations on Foreign Types

impl<K, V> Encoder for BTreeMap<K, V> where
    K: Encoder,
    V: Encoder, 

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

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

impl Encoder for i16

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

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

impl Encoder for i32

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

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

impl Encoder for String

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

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

impl<M> Encoder for Vec<M> where
    M: Encoder, 

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

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

impl Encoder for u16

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

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

impl<M> Encoder for Option<M> where
    M: Encoder, 

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

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

impl Encoder for u8

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

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

impl Encoder for u32

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

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

impl Encoder for i64

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

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

impl Encoder for bool

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

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

impl<M> Encoder for PhantomData<M> where
    M: Encoder, 

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

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

impl Encoder for i8

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

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

Loading content...

Implementors

impl Encoder for RequestHeader

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

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

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

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

fn encode<T>(&self, out: &mut T, version: Version) -> Result<(), IoError> where
    T: BufMut, 

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

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

fn encode<T>(&self, out: &mut T, version: Version) -> Result<(), IoError> where
    T: BufMut, 

Loading content...