Struct TranscodeWatcher 

pub struct TranscodeWatcher { /* private fields */ }

Directory-based transcode watcher.

Call TranscodeWatcher::scan to detect new files, and TranscodeWatcher::drain_pending to obtain TranscodeConfig values ready for submission to the job queue.

Implementations

impl TranscodeWatcher

pub fn new(config: WatchConfig) -> Self

Creates a new watcher from config.

pub fn config(&self) -> &WatchConfig

Returns the watcher configuration.

pub fn poll_interval(&self) -> Duration

Returns the poll interval as a Duration.

pub fn scan(&mut self) -> Result<usize>

Scans the watch directory for new eligible files.

Returns the number of new files enqueued.

Errors

Returns an error if the directory cannot be read.

pub fn pending(&self) -> Vec<&WatchEntry>

Returns all pending entries (without removing them from the queue).

pub fn drain_pending(&mut self) -> Vec<(WatchEntry, TranscodeConfig)>

Drains all pending entries into a Vec<TranscodeConfig> for submission to the job queue, marking each entry as Processing.

pub fn mark_done(&mut self, source: &Path) -> Result<()>

Marks a watch entry as successfully processed and applies the configured post-process action (move / delete / leave).

Errors

Returns an error if the file move or delete operation fails.

pub fn mark_failed(&mut self, source: &Path, reason: &str) -> Result<()>

Marks a watch entry as failed and applies the configured on-failure action.

Errors

Returns an error if the file operation fails.

pub fn queue_len(&self) -> usize

Returns the total number of queued entries.

pub fn status_counts(&self) -> WatchStatusCounts

Returns the number of entries in each status category.