Trait fluvio_smartmodule::dataplane::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 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 bool

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,

impl Encoder for u64

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 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 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, Global>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<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<M> Encoder for &Mwhere
    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 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 u8

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

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

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

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

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

Implementors

impl Encoder for SmartModuleInitErrorStatus

impl Encoder for SmartModuleTransformErrorStatus

impl Encoder for RequestKind

impl Encoder for ErrorCode

impl Encoder for LegacySmartModuleError

impl Encoder for SmartModuleKind

impl Encoder for RecordData

impl Encoder for BatchHeader

impl Encoder for RawRecords

impl Encoder for RecordHeader

impl Encoder for ReplicaKey

impl Encoder for SmartModuleAggregateInput

impl Encoder for SmartModuleAggregateOutput

impl Encoder for SmartModuleExtraParams

impl Encoder for SmartModuleInitInput

impl Encoder for SmartModuleInitOutput

impl Encoder for SmartModuleInput

impl Encoder for SmartModuleOutput

impl Encoder for RequestHeader

impl Encoder for SmartModuleInitRuntimeError

impl Encoder for SmartModuleTransformRuntimeError

impl Encoder for ApiVersionKey

impl Encoder for ApiVersionsRequest

impl Encoder for ApiVersionsResponse

impl Encoder for PlatformVersion

impl Encoder for ByteBuf

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 RecordSet<R>where
    R: BatchRecords,

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