Trait Decoder

Source
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 { ... }
}

Required Methods§

Source

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

Provided Methods§

Source

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

decode Fluvio compliant protocol values from buf

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types§

Source§

impl Decoder for bool

Source§

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

Source§

impl Decoder for f32

Source§

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

Source§

impl Decoder for f64

Source§

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

Source§

impl Decoder for i8

Source§

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

Source§

impl Decoder for i16

Source§

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

Source§

impl Decoder for i32

Source§

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

Source§

impl Decoder for i64

Source§

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

Source§

impl Decoder for u8

Source§

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

Source§

impl Decoder for u16

Source§

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

Source§

impl Decoder for u32

Source§

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

Source§

impl Decoder for u64

Source§

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

Source§

impl Decoder for String

Source§

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

Source§

impl Decoder for Duration

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

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

Source§

impl<M> Decoder for PhantomData<M>

Source§

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

Implementors§

Source§

impl Decoder for LegacySmartModuleError

Source§

impl Decoder for SmartModuleInitErrorStatus

Source§

impl Decoder for SmartModuleKind

Source§

impl Decoder for SmartModuleLookbackErrorStatus

Source§

impl Decoder for SmartModuleTransformErrorStatus

Source§

impl Decoder for RequestKind

Source§

impl Decoder for ErrorCode

Source§

impl Decoder for RecordData

Source§

impl Decoder for BatchHeader

Source§

impl Decoder for RawRecords

Source§

impl Decoder for RecordHeader

Source§

impl Decoder for ReplicaKey

Source§

impl Decoder for SchemaId

Source§

impl Decoder for Lookback

Source§

impl Decoder for SmartModuleAggregateInput

Source§

impl Decoder for SmartModuleAggregateOutput

Source§

impl Decoder for SmartModuleExtraParams

Source§

impl Decoder for SmartModuleInitInput

Source§

impl Decoder for SmartModuleInitOutput

Source§

impl Decoder for SmartModuleInitRuntimeError

Source§

impl Decoder for SmartModuleInput

Source§

impl Decoder for SmartModuleLookbackOutput

Source§

impl Decoder for SmartModuleLookbackRuntimeError

Source§

impl Decoder for SmartModuleOutput

Source§

impl Decoder for SmartModuleTransformRuntimeError

Source§

impl Decoder for RequestHeader

Source§

impl Decoder for ApiVersionKey

Source§

impl Decoder for ApiVersionsRequest

Source§

impl Decoder for ApiVersionsResponse

Source§

impl Decoder for PlatformVersion

Source§

impl Decoder for ByteBuf

Source§

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

Source§

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

Source§

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

Source§

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