Struct ProgressTracker 

pub struct ProgressTracker {
    pub name: String,
    pub items_processed: Arc<RwLock<u64>>,
    pub batches_processed: Arc<RwLock<u32>>,
    pub start_time: SystemTime,
    pub last_update: Arc<RwLock<SystemTime>>,
    pub update_interval: Duration,
}

Progress tracker for iterator operations

Fields

name: String

items_processed: Arc<RwLock<u64>>

batches_processed: Arc<RwLock<u32>>

start_time: SystemTime

last_update: Arc<RwLock<SystemTime>>

update_interval: Duration

Implementations

impl ProgressTracker

pub fn new(name: impl Into<String>) -> Self

Create a new progress tracker

pub fn with_update_interval(self, interval: Duration) -> Self

Set the update interval for progress reports

pub async fn update_batch(&self, batch_size: usize)

Update progress with new batch

pub async fn stats(&self) -> ProgressStats

Get current statistics

pub async fn reset(&self)

Reset progress statistics