Struct fluvio::dataplane::batch::Batch [−][src]
pub struct Batch<R = Vec<Record<RecordData>, Global>> { pub base_offset: i64, pub batch_len: i32, pub header: BatchHeader, // some fields omitted }
Fields
base_offset: i64
batch_len: i32
header: BatchHeader
Implementations
get last offset delta
add new record, this will update the offset to correct
computed last offset which is base offset + number of records
Trait Implementations
Auto Trait Implementations
impl<R> RefUnwindSafe for Batch<R> where
R: RefUnwindSafe,
impl<R> UnwindSafe for Batch<R> where
R: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more