Struct ProxyTranscodeQueue 

pub struct ProxyTranscodeQueue { /* private fields */ }

Priority-based proxy transcode queue.

Higher-priority jobs are dispatched first. Within the same priority, earlier submission time wins (FIFO).

Implementations

impl ProxyTranscodeQueue

pub fn new() -> Self

Create an empty transcode queue.

pub fn submit(&mut self, request: ProxyRequest) -> String

Submit a new request and return the job ID.

pub fn next_job(&mut self) -> Option<&mut ProxyTranscodeJob>

Get the next queued job (highest priority, earliest submitted).

pub fn start_job(&mut self, id: &str, started_at_ms: u64)

Mark a job as started at the given timestamp.

pub fn complete_job(&mut self, id: &str, output: &str)

Mark a job as successfully completed.

pub fn fail_job(&mut self, id: &str, error: &str)

Mark a job as failed with an error message.

pub fn cancel_job(&mut self, id: &str)

Cancel a queued job.

pub fn get(&self, id: &str) -> Option<&ProxyTranscodeJob>

Get a job by ID (immutable).

pub fn len(&self) -> usize

Total number of jobs (all statuses).

pub fn is_empty(&self) -> bool

Whether the queue has any jobs at all.

pub fn iter(&self) -> impl Iterator<Item = &ProxyTranscodeJob>

Iterate over all jobs.

Trait Implementations

impl Debug for ProxyTranscodeQueue

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

Formats the value using the given formatter.

impl Default for ProxyTranscodeQueue

fn default() -> ProxyTranscodeQueue

Returns the “default value” for a type.