Struct ValidatedBatch 

pub struct ValidatedBatch<'a> {
    pub header: &'a RecordBatchHeader,
    pub total_len: usize,
    /* private fields */
}

A single complete v2 batch located within a larger buffer, together with its already-validated header.

validate_one_v2_batch returns this type.

Fields

header: &'a RecordBatchHeader

The fixed 61-byte header, reinterpreted in place, zero-copy.

total_len: usize

Total on-disk and wire length of this batch in bytes, which is 12 + batch_length, that is the header plus the body.

Implementations

impl ValidatedBatch<'_>

pub fn validate_records( &self, policy: RecordDecompressionPolicy, ) -> Result<(), RecordsError>

Validates that the body contains exactly the number of structurally valid records declared by the batch header.

Uncompressed records are parsed directly from the input slice. A compressed body is decompressed once under policy, parsed, and then discarded; the original compressed bytes remain available to callers for verbatim append.

Errors

Returns a records or compression error when the body is malformed, exceeds the decompression policy, contains fewer records than declared, or has trailing bytes after the declared records.

pub fn validate_records_with( &self, policy: RecordDecompressionPolicy, visit: impl FnMut(&Record<'_>), ) -> Result<(), RecordsError>

Validates the records and calls visit for each borrowed record.

This combines structural validation with callers’ metadata checks while keeping compressed batches on the borrowed path.

Errors

Returns the same errors as Self::validate_records.

Trait Implementations

impl<'a> Debug for ValidatedBatch<'a>

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

Formats the value using the given formatter.