Struct fluvio_smartstream::Record [−][src]
pub struct Record<B = RecordData> { 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]
pub fn add_base_offset(&mut self, relative_base_offset: i64)
[src]add offset delta with new relative base offset
pub fn into_value(self) -> B
[src]
pub fn into_value(self) -> B
[src]Consumes this record, returning the inner value
impl Record<RecordData>
[src]
impl Record<RecordData>
[src]pub fn new<V>(value: V) -> Record<RecordData> where
V: Into<RecordData>,
[src]
V: Into<RecordData>,
pub fn new_key_value<K, V>(key: K, value: V) -> Record<RecordData> where
V: Into<RecordData>,
K: Into<RecordKey>,
[src]
V: Into<RecordData>,
K: Into<RecordKey>,
Trait Implementations
Auto Trait Implementations
impl<B> RefUnwindSafe for Record<B> where
B: RefUnwindSafe,
B: RefUnwindSafe,
impl<B> Send for Record<B> where
B: Send,
B: Send,
impl<B> Sync for Record<B> where
B: Sync,
B: Sync,
impl<B> Unpin for Record<B> where
B: Unpin,
B: Unpin,
impl<B> UnwindSafe for Record<B> where
B: UnwindSafe,
B: UnwindSafe,
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
fn in_current_span(self) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]