Struct BatchScheduler 

pub struct BatchScheduler { /* private fields */ }

Scheduler for batch jobs.

Implementations

impl BatchScheduler

pub fn new(insight_store: Arc<InsightStore>) -> Self

Create a new scheduler with default jobs.

pub fn add_job(&mut self, job: Arc<dyn BatchJob>)

Add a custom job.

pub async fn run_job( &self, job_type: JobType, input: &BatchInput, ) -> Result<JobRun, String>

Run a specific job type immediately.

pub async fn run_all(&self, input: &BatchInput) -> Vec<JobRun>

Run all jobs.

pub async fn history(&self) -> Vec<JobRun>

Get job history.

pub async fn last_run(&self, job_type: JobType) -> Option<JobRun>

Get last run for a job type.

pub fn total_runs(&self) -> u64

Total runs executed.

pub fn start_background( self: Arc<Self>, input_receiver: Receiver<BatchInput>, ) -> JoinHandle<()>

Start background scheduling (non-blocking).

pub fn stop(&self)

Stop background scheduling.