Struct AppStateInner 

pub struct AppStateInner {
    pub service: Arc<CameraService>,
}

The state behind AppState.

Fields

service: Arc<CameraService>

The cameras.

Implementations

impl AppStateInner

pub fn new(service: Arc<CameraService>) -> AppState

State for a service, with alarm tracking started if the feature is on.

Task budget

The alarm aggregator is one task for the whole service, not one per camera: it reads the already-merged event bus. The workspace budget allows no feature more than one task per camera, and events already spends that one.

Methods from Deref<Target = CameraService>

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

Look up one camera.

pub fn all(&self) -> impl Iterator<Item = &Arc<Camera>>

Every camera, in stable id order.

pub fn subscribe_events(&self) -> Receiver<Event>

Attach to the merged analytics-event stream from all cameras.

pub fn spawned_task_count(&self) -> usize

How many long-lived tasks this service spawned.

One supervised link per task. The workspace budget allows no feature more than one task per camera, and tests/task_budget.rs asserts it against this number.

pub fn shutdown(&self)

Stop every camera. Supervisors wind down asynchronously.

Trait Implementations

impl Deref for AppStateInner

So a handler written against the service keeps working unchanged.

type Target = CameraService

The resulting type after dereferencing.

fn deref(&self) -> &CameraService

Dereferences the value.