Trait fluvio_smartmodule::dataplane::core::Decoder

pub trait Decoder: Sized + Default {
    // Required method
    fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>
       where T: Buf;

    // Provided method
    fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>
       where T: Buf,
             Self: Default { ... }
}

Required Methods

fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>where T: Buf,

Provided Methods

fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>where T: Buf, Self: Default,

decode Fluvio compliant protocol values from buf

Implementations on Foreign Types

impl Decoder for bool

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl<K, V> Decoder for BTreeMap<K, V, Global>where K: Decoder + Ord, V: Decoder,

fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for i16

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for String

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for u16

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for i64

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for i8

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for u64

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for u32

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl<M> Decoder for Option<M>where M: Default + Decoder,

fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for i32

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl<M> Decoder for PhantomData<M>where M: Default + Decoder,

fn decode<T>(&mut self, _src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl Decoder for u8

fn decode<T>(&mut self, src: &mut T, _version: i16) -> Result<(), Error>where T: Buf,

impl<M> Decoder for Vec<M, Global>where M: Default + Decoder,

fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>where T: Buf,

Implementors

impl Decoder for SmartModuleInitErrorStatus

impl Decoder for SmartModuleTransformErrorStatus

impl Decoder for RequestKind

impl Decoder for ErrorCode

impl Decoder for LegacySmartModuleError

impl Decoder for SmartModuleKind

impl Decoder for RecordData

impl Decoder for BatchHeader

impl Decoder for RawRecords

impl Decoder for RecordHeader

impl Decoder for ReplicaKey

impl Decoder for SmartModuleAggregateInput

impl Decoder for SmartModuleAggregateOutput

impl Decoder for SmartModuleExtraParams

impl Decoder for SmartModuleInitInput

impl Decoder for SmartModuleInitOutput

impl Decoder for SmartModuleInput

impl Decoder for SmartModuleOutput

impl Decoder for RequestHeader

impl Decoder for SmartModuleInitRuntimeError

impl Decoder for SmartModuleTransformRuntimeError

impl Decoder for ApiVersionKey

impl Decoder for ApiVersionsRequest

impl Decoder for ApiVersionsResponse

impl Decoder for PlatformVersion

impl Decoder for ByteBuf

impl<B> Decoder for Record<B>where B: Decoder,

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

impl<R> Decoder for RecordSet<R>where R: BatchRecords,

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