Struct fluvio::dataplane::record::BatchHeader
source · pub struct BatchHeader {
pub partition_leader_epoch: i32,
pub magic: i8,
pub crc: u32,
pub attributes: i16,
pub last_offset_delta: i32,
pub first_timestamp: i64,
pub max_time_stamp: i64,
pub producer_id: i64,
pub producer_epoch: i16,
pub first_sequence: i32,
}
Fields§
§partition_leader_epoch: i32
§magic: i8
§crc: u32
§attributes: i16
§last_offset_delta: i32
Indicates the count from the beginning of the batch to the end
Adding this to the base_offset will give the offset of the last record in this batch
first_timestamp: i64
§max_time_stamp: i64
§producer_id: i64
§producer_epoch: i16
§first_sequence: i32
Implementations§
source§impl BatchHeader
impl BatchHeader
pub fn set_compression(&mut self, compression: Compression)
pub fn has_schema(&self) -> bool
sourcepub fn set_schema_id(&mut self)
pub fn set_schema_id(&mut self)
set has schema id attr flag
Trait Implementations§
source§impl Clone for BatchHeader
impl Clone for BatchHeader
source§fn clone(&self) -> BatchHeader
fn clone(&self) -> BatchHeader
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for BatchHeader
impl Debug for BatchHeader
source§impl Decoder for BatchHeader
impl Decoder for BatchHeader
source§impl Default for BatchHeader
impl Default for BatchHeader
source§fn default() -> BatchHeader
fn default() -> BatchHeader
Returns the “default value” for a type. Read more
source§impl Encoder for BatchHeader
impl Encoder for BatchHeader
source§impl ProducerBatchHeader for BatchHeader
impl ProducerBatchHeader for BatchHeader
fn set_first_timestamp(&mut self, timestamp: i64)
fn set_max_time_stamp(&mut self, timestamp: i64)
Auto Trait Implementations§
impl Freeze for BatchHeader
impl RefUnwindSafe for BatchHeader
impl Send for BatchHeader
impl Sync for BatchHeader
impl Unpin for BatchHeader
impl UnwindSafe for BatchHeader
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more