Struct fluvio_smartmodule::dataplane::record::ConsumerRecord

pub struct ConsumerRecord<B = Record<RecordData>> {
    pub offset: i64,
    pub partition: u32,
    pub record: B,
    /* private fields */
}

Record that can be used by Consumer which needs access to metadata

Fields

offset: i64

The offset of this Record into its partition

partition: u32

The partition where this Record is stored

record: B

The Record contents

Implementations

impl<B> ConsumerRecord<B>

pub fn offset(&self) -> i64

The offset from the initial offset for a given stream.

pub fn partition(&self) -> u32

The partition where this Record is stored.

pub fn into_inner(self) -> B

Returns the inner representation of the Record

pub fn inner(&self) -> &B

Returns a ref to the inner representation of the Record

impl ConsumerRecord<Record<RecordData>>

pub fn key(&self) -> Option<&[u8]>

Returns the contents of this Record’s key, if it exists

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

Returns the contents of this Record’s value

pub fn timestamp(&self) -> i64

Return the timestamp of the Record

Trait Implementations

impl AsRef<[u8]> for ConsumerRecord<Record<RecordData>>

fn as_ref(&self) -> &[u8]

Converts this type into a shared reference of the (usually inferred) input type.