Type Definition fluvio_dataplane_protocol::batch::DefaultBatch [−][src]
type DefaultBatch = Batch<DefaultBatchRecords>;
Implementations
impl DefaultBatch[src]
pub fn new(records: Vec<DefaultRecord>) -> Self[src]
Create a new batch from a Vec of DefaultRecords
pub fn add_record(&mut self, record: DefaultRecord)[src]
add new record, this will update the offset to correct
pub fn computed_last_offset(&self) -> Offset[src]
computed last offset which is base offset + number of records