Struct RuntimeHandle 

pub struct RuntimeHandle { /* private fields */ }

Cloneable handle to the runtime.

Provides the same control surface as Runtime — add/remove feeds, subscribe to health and output events, and trigger shutdown.

Obtain via Runtime::handle().

Implementations

impl RuntimeHandle

pub fn feed_count(&self) -> Result<usize, NvError>

Number of currently active feeds.

pub fn max_feeds(&self) -> usize

Maximum allowed concurrent feeds.

pub fn uptime(&self) -> Duration

Elapsed time since the runtime was created.

Monotonically increasing. Useful for uptime dashboards and health checks.

pub fn diagnostics(&self) -> Result<RuntimeDiagnostics, NvError>

Get a consolidated diagnostics snapshot of the runtime and all feeds.

See Runtime::diagnostics() for details.

pub fn health_subscribe(&self) -> Receiver<HealthEvent>

Subscribe to aggregate health events from all feeds.

pub fn output_subscribe(&self) -> Receiver<SharedOutput>

Subscribe to aggregate output from all feeds.

Bounded by the configured output_capacity. Slow subscribers receive RecvError::Lagged. Channel saturation is reported via HealthEvent::OutputLagged (sentinel-observed, not per-subscriber loss).

pub fn add_feed(&self, config: FeedConfig) -> Result<FeedHandle, NvError>

Add a new feed to the runtime.

Errors

See Runtime::add_feed().

pub fn create_batch( &self, processor: Box<dyn BatchProcessor>, config: BatchConfig, ) -> Result<BatchHandle, NvError>

Create a shared batch coordinator.

See Runtime::create_batch() for details.

pub fn remove_feed(&self, feed_id: FeedId) -> Result<(), NvError>

Remove a feed by ID, stopping it gracefully.

Errors

Returns RuntimeError::FeedNotFound if the ID does not exist.

pub fn shutdown(&self) -> Result<(), NvError>

Trigger graceful shutdown of all feeds.

Signals all worker threads to stop, waits for them to terminate, and returns. Unlike Runtime::shutdown(), this does not consume the handle — it can be called from any clone.

Trait Implementations

impl Clone for RuntimeHandle

fn clone(&self) -> RuntimeHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.