Struct CameraManager

pub struct CameraManager {
    dev_prov: DeviceProvider,
    pipelines: Arc<RwLock<HashMap<String, Pipeline>>>,
    calibrators: Arc<Mutex<HashMap<String, Calibrator>>>,
    mjpeg_streams: Arc<Mutex<HashMap<String, MjpegStream>>>,
    restart_tx: Sender<()>,
    subsys_man: SubsysManager,
}

The camera manager

This manages all of the GStreamer pipelines. It also handles device events.

Fields

dev_prov: DeviceProvider

pipelines: Arc<RwLock<HashMap<String, Pipeline>>>

calibrators: Arc<Mutex<HashMap<String, Calibrator>>>

mjpeg_streams: Arc<Mutex<HashMap<String, MjpegStream>>>

restart_tx: Sender<()>

subsys_man: SubsysManager

Implementations

impl CameraManager

pub async fn new(nt: NtConn, restart_tx: Sender<()>) -> Self

Initialize a camera manager

You MUST call [gstreamer::init] first.

pub async fn restart(&self)

fn get_id(dev: &Device) -> String

Get unique identifier for the given device

pub async fn update_pipeline(&self, dev_id: String)

Update the given pipeline

pub fn devices(&self) -> Vec<Camera>

List connected cameras

pub async fn calib_step(&self, name: String) -> usize

Run a calibration step

pub async fn mjpeg_stream(&self, name: String) -> MjpegStream

Get an MJPEG stream

pub(crate) fn add_subsys<S: Subsystem>( pipeline: &Pipeline, cam: &Element, cam_config: Camera, enabled: bool, ) -> Receiver<Option<Vec<u8>>>

Add subsystem to pipeline

pub(crate) fn add_calib( pipeline: &Pipeline, cam: &Element, cam_config: Camera, ) -> Calibrator

Add Calibrator to pipeline

pub(crate) fn add_mjpeg( pipeline: &Pipeline, cam: &Element, cam_config: Camera, ) -> MjpegStream

Add MjpegStream to pipeline

pub async fn run(&self, name: String) -> Result<(), Box<dyn Error>>

pub async fn start(&self, name: String)

Start the given camera’s pipeline

pub async fn pause(&self, name: String)

Pause the given camera’s pipeline

pub async fn calibrators(&self) -> MutexGuard<'_, HashMap<String, Calibrator>>

pub async fn mjpeg_streams( &self, ) -> MutexGuard<'_, HashMap<String, MjpegStream>>

Trait Implementations

impl Clone for CameraManager

fn clone(&self) -> CameraManager

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.