Struct fluvio_dataplane_protocol::batch::Batch [−][src]
pub struct Batch<R = MemoryRecords> { pub base_offset: Offset, pub batch_len: i32, pub header: BatchHeader, // some fields omitted }
Fields
base_offset: Offset
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