Struct fluvio::dataplane::record::Record [−][src]
pub struct Record<B> where
B: Default, { pub preamble: RecordHeader, pub key: Option<B>, pub value: B, pub headers: i64, }
Fields
preamble: RecordHeader
key: Option<B>
value: B
headers: i64
Implementations
impl<B> Record<B> where
B: Default,
[src]
impl<B> Record<B> where
B: Default,
[src]pub fn get_offset_delta(&self) -> i64
[src]
pub fn add_base_offset(&mut self, relative_base_offset: i64)
[src]
add offset delta with new relative base offset
pub fn value(&self) -> &B
[src]
Returns a reference to the inner value
pub fn key(&self) -> Option<&B>
[src]
Returns a reference to the inner key if it exists
pub fn into_value(self) -> B
[src]
Consumes this record, returning the inner value
pub fn into_key(self) -> Option<B>
[src]
Consumes this record, returning the inner key if it esists
Trait Implementations
Auto Trait Implementations
impl<B> RefUnwindSafe for Record<B> where
B: RefUnwindSafe,
impl<B> RefUnwindSafe for Record<B> where
B: RefUnwindSafe,
impl<B> UnwindSafe for Record<B> where
B: UnwindSafe,
impl<B> UnwindSafe for Record<B> where
B: UnwindSafe,
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]