Struct ProxyGenerationQueue 

pub struct ProxyGenerationQueue { /* private fields */ }

Background proxy generation queue with progress tracking.

Implementations

impl ProxyGenerationQueue

pub fn new(max_concurrent: usize) -> Self

Create a new generation queue.

pub fn enqueue(&mut self, source_key: String, config: ProxyWorkflowConfig)

Enqueue a proxy generation job.

pub fn start_next(&mut self) -> Option<String>

Start the next pending job if capacity allows.

Returns the source key of the started job, or None if queue is empty or at capacity.

pub fn update_progress( &mut self, source_key: &str, fraction: f64, stage: &str, eta: f64, ) -> bool

Update progress for an in-progress job.

pub fn mark_completed(&mut self, source_key: &str) -> bool

Mark a job as completed.

pub fn mark_job_failed(&mut self, source_key: &str, error: String) -> bool

Mark a job as failed.

pub fn get_progress(&self, source_key: &str) -> Option<&ProxyJobProgress>

Get progress for a specific job.

pub fn overall_progress(&self) -> f64

Total overall progress (0.0–1.0) across all jobs.

pub fn pending_count(&self) -> usize

Number of pending jobs.

pub fn in_progress_count(&self) -> usize

Number of in-progress jobs.

pub fn completed_count(&self) -> usize

Number of completed jobs.

pub fn failed_count(&self) -> usize

Number of failed jobs.

pub fn failed_jobs(&self) -> &[(String, String)]

Get failed jobs with their error messages.

pub fn is_idle(&self) -> bool

Whether the queue has no more work (pending or in-progress).

Trait Implementations

impl Debug for ProxyGenerationQueue

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

Formats the value using the given formatter.