Struct RuntimeBuilder 

pub struct RuntimeBuilder { /* private fields */ }

Builder for constructing a Runtime.

The runtime uses a default media backend unless a custom MediaIngressFactory is supplied via ingress_factory().

Example

use nv_runtime::Runtime;

let runtime = Runtime::builder()
    .max_feeds(16)
    .build()
    .expect("failed to build runtime");

Implementations

impl RuntimeBuilder

pub fn max_feeds(self, max: usize) -> Self

Set the maximum number of concurrent feeds. Default: 64.

pub fn health_capacity(self, cap: usize) -> Self

Set the health broadcast channel capacity. Default: 256.

pub fn output_capacity(self, cap: usize) -> Self

Set the output broadcast channel capacity. Default: 256.

Controls how many OutputEnvelopes the aggregate output subscription channel can buffer before the ring buffer wraps.

When the internal sentinel receiver detects ring-buffer wrap, the runtime emits a global HealthEvent::OutputLagged event carrying the sentinel-observed per-event delta (not cumulative). This indicates channel saturation / backpressure risk — it does not guarantee that any specific external subscriber lost messages.

pub fn ingress_factory(self, factory: Box<dyn MediaIngressFactory>) -> Self

Set a custom MediaIngressFactory.

By default the runtime uses the built-in media backend (DefaultMediaFactory). Replace this for testing or alternative backends.

pub fn feed_join_timeout(self, timeout: Duration) -> Self

Set the maximum time to wait for a feed worker thread to join during shutdown or removal. Default: 10s.

If a feed thread does not finish within this timeout, it is detached and a health event is emitted.

pub fn coordinator_join_timeout(self, timeout: Duration) -> Self

Set the maximum time to wait for a batch coordinator thread to join during shutdown. Default: 10s.

pub fn custom_pipeline_policy(self, policy: CustomPipelinePolicy) -> Self

Set the custom pipeline security policy.

Controls whether SourceSpec::Custom pipeline fragments are accepted. Default: Reject.

Set to AllowTrusted when pipeline strings originate from trusted sources (e.g., hard-coded application code).

pub fn build(self) -> Result<Runtime, NvError>

Build the runtime.

Errors

Returns ConfigError::InvalidCapacity if health_capacity or output_capacity is zero.