Struct fluvio::dataplane::record::RecordSet [−][src]
Expand description
Represents sets of batches in storage
Fields
batches: Vec<Batch<Vec<Record<RecordData>, Global>>, Global>
Implementations
impl RecordSet
[src]
impl RecordSet
[src]pub fn add(self, batch: Batch<Vec<Record<RecordData>, Global>>) -> RecordSet
[src]
pub fn last_offset(&self) -> Option<i64>
[src]
pub fn last_offset(&self) -> Option<i64>
[src]this is next offset to be fetched
pub fn total_records(&self) -> usize
[src]
pub fn total_records(&self) -> usize
[src]total records
pub fn base_offset(&self) -> i64
[src]
pub fn base_offset(&self) -> i64
[src]return base offset
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for RecordSet
impl Send for RecordSet
impl Sync for RecordSet
impl Unpin for RecordSet
impl UnwindSafe for RecordSet
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]impl<T> AsyncConnector for T where
T: Send + Sync,
[src]
T: Send + Sync,