Struct ResumableBatchGenerator 

pub struct ResumableBatchGenerator { /* private fields */ }

Resumable batch generator with checkpoint support.

This generator can save progress and resume from where it left off, useful for generating very large batches of keys.

Example

use rustywallet_batch::checkpoint::ResumableBatchGenerator;
use rustywallet_batch::mmap::OutputFormat;

// Start or resume generation
let mut generator = ResumableBatchGenerator::new(
    "my-job",
    1_000_000,
    "keys.txt",
    "checkpoint.json",
);

generator.generate_with_progress(|progress| {
    println!("Progress: {:.1}%", progress);
}).unwrap();

Implementations

impl ResumableBatchGenerator

pub fn new( job_id: &str, total_count: usize, output_path: &str, checkpoint_path: &str, ) -> Self

Create a new resumable generator.

If a checkpoint exists, it will be loaded and generation will resume.

pub fn new_incremental( job_id: &str, total_count: usize, output_path: &str, checkpoint_path: &str, start_key: &str, ) -> Self

Create a new resumable generator for incremental mode.

pub fn chunk_size(self, size: usize) -> Self

Set the chunk size for generation.

pub fn checkpoint_interval(self, interval: usize) -> Self

Set the checkpoint interval.

pub fn parallel(self, enabled: bool) -> Self

Enable or disable parallel generation.

pub fn progress(&self) -> &Checkpoint

Get current progress.

pub fn generate_with_progress<F>( &mut self, progress_callback: F, ) -> Result<usize, BatchError>

where F: FnMut(f64),

Generate keys with progress callback.

pub fn generate(&mut self) -> Result<usize, BatchError>

Generate keys without progress callback.

pub fn cleanup(&self) -> Result<(), BatchError>

Clean up checkpoint file after successful completion.