Struct fluvio_smartmodule::SmartModuleRecord

pub struct SmartModuleRecord { /* private fields */ }

Wrapper on Record that provides access to the base offset and timestamp

Implementations

impl SmartModuleRecord

pub fn new( inner_record: Record, base_offset: Offset, base_timestamp: Timestamp ) -> Self

pub fn into_inner(self) -> Record

pub fn timestamp(&self) -> Timestamp

pub fn offset(&self) -> Offset

pub fn key(&self) -> Option<&RecordData>

pub fn value(&self) -> &RecordData

Methods from Deref<Target = Record>

pub fn get_header(&self) -> &RecordHeader

return reference to header

pub fn get_mut_header(&mut self) -> &mut RecordHeader

return mutable reference to header

pub fn add_base_offset(&mut self, relative_base_offset: i64)

add offset delta with new relative base offset

pub fn value(&self) -> &B

Returns a reference to the inner value

pub fn key(&self) -> Option<&B>

Returns a reference to the inner key if it exists

pub fn timestamp_delta(&self) -> i64

pub fn offset_delta(&self) -> i64

Trait Implementations

impl Clone for SmartModuleRecord

fn clone(&self) -> SmartModuleRecord

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SmartModuleRecord

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

Formats the value using the given formatter.

impl Default for SmartModuleRecord

fn default() -> SmartModuleRecord

Returns the “default value” for a type.

impl Deref for SmartModuleRecord

type Target = Record

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for SmartModuleRecord

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl From<SmartModuleRecord> for Record

fn from(sm_record: SmartModuleRecord) -> Self

Converts to this type from the input type.