Trait fluvio_protocol::core::Encoder

pub trait Encoder {
    // Required methods
    fn write_size(&self, version: Version) -> usize;
    fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error>
       where T: BufMut;

    // Provided method
    fn as_bytes(&self, version: Version) -> Result<Bytes, Error> { ... }
}

Required Methods

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

size of this object in bytes

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

where T: BufMut,

encoding contents for buffer

Provided Methods

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

Object Safety

This trait is not object safe.

Implementations on Foreign Types

impl Encoder for bool

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

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

where T: BufMut,

impl Encoder for f32

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

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

where T: BufMut,

impl Encoder for f64

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

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

where T: BufMut,

impl Encoder for i8

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

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

where T: BufMut,

impl Encoder for i16

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

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

where T: BufMut,

impl Encoder for i32

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

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

where T: BufMut,

impl Encoder for i64

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

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

where T: BufMut,

impl Encoder for u8

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

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

where T: BufMut,

impl Encoder for u16

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

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

where T: BufMut,

impl Encoder for u32

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

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

where T: BufMut,

impl Encoder for u64

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

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

where T: BufMut,

impl Encoder for String

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

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

where T: BufMut,

impl Encoder for Duration

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

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

where T: BufMut,

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

where K: Encoder, V: Encoder,

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

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

where T: BufMut,

impl<M> Encoder for Option<M>

where M: Encoder,

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

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

where T: BufMut,

impl<M> Encoder for &M

where M: Encoder,

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

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

where T: BufMut,

impl<M> Encoder for Vec<M>

where M: Encoder,

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

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

where T: BufMut,

impl<M> Encoder for PhantomData<M>

where M: Encoder,

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

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

where T: BufMut,

Implementors

impl Encoder for ByteBuf