Struct RecorderManager 

pub struct RecorderManager { /* private fields */ }

Owns and supervises the per-camera recorder tasks.

Implementations

impl RecorderManager

pub fn new(pool: SqlitePool, cfg: Arc<Config>) -> Arc<Self>

pub async fn start_all(self: &Arc<Self>) -> Result<()>

Start recorders for all cameras that should record.

pub async fn reconcile(self: &Arc<Self>, camera_id: &str)

Reconcile a single camera’s recorder against its current DB state.

pub async fn stop(self: &Arc<Self>, camera_id: &str)

Stop a camera’s recorder task, killing its FFmpeg process. Returns only once the task is actually gone (aborting it if it does not stop promptly).

pub async fn shutdown(self: &Arc<Self>)

Stop all recorder tasks (graceful shutdown).

pub async fn active_ids(&self) -> Vec<String>

Camera ids currently being supervised.