Struct fluvio::consumer::Record [−][src]
pub struct Record { /* fields omitted */ }
The individual record for a given stream.
Implementations
impl Record
[src]
pub fn offset(&self) -> i64
[src]
The offset from the initial offset for a given stream.
pub fn key(&self) -> Option<&[u8]>
[src]
Returns the contents of this Record’s key, if it exists
pub fn value(&self) -> &[u8]ⓘ
[src]
Returns the contents of this Record’s value
pub fn into_inner(self) -> DefaultRecord
[src]
Returns the inner representation of the Record
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Record
impl Send for Record
impl Sync for Record
impl Unpin for Record
impl UnwindSafe for Record
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Erased for T
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,