Struct fluvio::dataplane::record::ConsumerRecord

pub struct ConsumerRecord {
    pub offset: i64,
    pub partition: u32,
    pub record: Record,
    /* 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: Record

The Record contents

Implementations

impl ConsumerRecord

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) -> Record

Returns the inner representation of the Record

pub fn inner(&self) -> &Record

Returns a ref to the inner representation of the Record

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

Returns record key

pub fn get_value(&self) -> &RecordData

Returns record value

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

Returns the contents of this Record’s key as a byte slice

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

Returns the contents of this Record’s value as a byte slice

pub fn timestamp(&self) -> i64

Return the timestamp of the Record

Trait Implementations

impl AsRef<[u8]> for ConsumerRecord

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

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