Struct IngestHeader 

pub struct IngestHeader {
    pub batch_id: u64,
    pub timestamp_ns: u64,
    pub record_count: u32,
    pub payload_length: u32,
    pub payload_crc: u32,
    pub topic_id: u32,
}

Fields

batch_id: u64

timestamp_ns: u64

record_count: u32

payload_length: u32

payload_crc: u32

topic_id: u32

Implementations

impl IngestHeader

pub const SIZE: usize = 32

pub fn new( batch_id: u64, timestamp_ns: u64, record_count: u32, payload_length: u32, payload_crc: u32, ) -> Self

pub fn with_topic( batch_id: u64, timestamp_ns: u64, record_count: u32, payload_length: u32, payload_crc: u32, topic_id: u32, ) -> Self

pub fn parse(buf: &[u8]) -> Result<Self>

pub fn encode_into(&self, buf: &mut [u8])

pub fn validate_payload(&self, payload: &[u8]) -> Result<()>

Trait Implementations

impl Clone for IngestHeader

fn clone(&self) -> IngestHeader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IngestHeader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for IngestHeader

fn default() -> IngestHeader

Returns the “default value” for a type.

impl Copy for IngestHeader