Struct fluvio_smartmodule::dataplane::smartmodule::SmartModuleInput

pub struct SmartModuleInput { /* private fields */ }

A single SmartModule input record

Implementations

impl SmartModuleInput

pub fn new( raw_bytes: Vec<u8>, base_offset: Offset, base_timestamp: Timestamp ) -> Self

pub fn base_offset(&self) -> Offset

pub fn set_base_offset(&mut self, base_offset: Offset)

pub fn base_timestamp(&self) -> Timestamp

pub fn set_base_timestamp(&mut self, base_timestamp: Timestamp)

pub fn raw_bytes(&self) -> &[u8]

pub fn into_raw_bytes(self) -> Vec<u8>

pub fn parts(self) -> (Vec<u8>, Vec<u8>)

pub fn try_into_records(self, version: Version) -> Result<Vec<Record>, Error>

👎Deprecated: use SmartModuleRecord instead. Read more here: https://www.fluvio.io/smartmodules/smdk/smartmodulerecord/.

Creates an instance of Record from the raw bytes and ignoring the base offset and timestamp. This method is used to keep backwards compatibility with SmartModule engines previous to Version 21.

pub fn try_into_smartmodule_records( self, version: Version ) -> Result<Vec<SmartModuleRecord>, Error>

Attempts to map the internally encoded records into a vector of SmartModuleRecord by decoding the raw bytes and filling up the base offset and timestamp fields.

pub fn try_from_records( records: Vec<Record>, version: Version ) -> Result<Self, Error>

Attempts to map the Record vector and build a SmartModuleInput instance from it.

Trait Implementations

impl Clone for SmartModuleInput

fn clone(&self) -> SmartModuleInput

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SmartModuleInput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Decoder for SmartModuleInput

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

where T: Buf,

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

where T: Buf,

decode Fluvio compliant protocol values from buf

impl Default for SmartModuleInput

fn default() -> SmartModuleInput

Returns the “default value” for a type.

impl Display for SmartModuleInput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Encoder for SmartModuleInput

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

where T: BufMut,

encoding contents for buffer

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

size of this object in bytes

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