Struct ChunkProgress 

pub struct ChunkProgress { /* private fields */ }

Mutable, invariant-preserving progress for one bounded chunk.

Implementations

impl ChunkProgress

pub const fn new(size: ChunkSize) -> ChunkProgress

Starts an empty chunk with a validated nonzero size.

pub fn from_counts( size: ChunkSize, counts: ChunkCounts, ) -> Result<ChunkProgress, ChunkError>

Restores a validated in-memory progress snapshot.

Errors

Returns ChunkError::SizeExceeded when counts.read() exceeds the configured chunk size.

pub const fn size(self) -> ChunkSize

Returns the configured size.

pub const fn counts(self) -> ChunkCounts

Returns the current validated counts.

pub fn is_full(self) -> bool

Returns whether no more items may be read into this chunk.

pub fn record_read(&mut self) -> Result<(), ChunkError>

Records one successfully read item.

Errors

Returns ChunkError::SizeExceeded when the chunk is already full, or ChunkError::CountOverflow on arithmetic exhaustion.

pub fn record_processed(&mut self) -> Result<(), ChunkError>

Classifies one previously read item as successfully processed.

Errors

Returns ChunkError::ClassifiedExceedsRead when no unclassified read item remains, or ChunkError::CountOverflow on exhaustion.

pub fn record_filtered(&mut self) -> Result<(), ChunkError>

Classifies one previously read item as filtered.

Errors

Returns ChunkError::ClassifiedExceedsRead when no unclassified read item remains, or ChunkError::CountOverflow on exhaustion.

pub fn record_written(&mut self, count: ChunkCount) -> Result<(), ChunkError>

Records writer acknowledgement for count processed items.

Errors

Returns ChunkError::WrittenExceedsProcessed when the aggregate exceeds processed output, or ChunkError::CountOverflow on exhaustion.

Trait Implementations

impl Clone for ChunkProgress

fn clone(&self) -> ChunkProgress

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ChunkProgress

impl Debug for ChunkProgress

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

Formats the value using the given formatter.

impl Eq for ChunkProgress

impl PartialEq for ChunkProgress

fn eq(&self, other: &ChunkProgress) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ChunkProgress