Struct EngineBuilder 

pub struct EngineBuilder { /* private fields */ }

Fluent builder for an Engine. Takes plain owned specs instead of a deserialized config schema, so consumers never adopt stream-center’s TOML.

use arcly_stream::prelude::*;

let engine = Engine::builder()
    .max_publishers(1_000)
    .application(AppSpec::new("live").broadcast_capacity(8192))
    .build();
assert_eq!(engine.list_apps().len(), 1);

Implementations

impl EngineBuilder

pub fn new() -> Self

A fresh builder with default config, no apps, and permit-all auth.

pub fn max_publishers(self, n: usize) -> Self

Set the hard cap on concurrent publishing streams.

pub fn config(self, config: EngineConfig) -> Self

Replace the whole engine config.

pub fn application(self, app: AppSpec) -> Self

Register an application.

pub fn applications(self, apps: impl IntoIterator<Item = AppSpec>) -> Self

Register many applications at once.

pub fn observer<O: Observer>(self, observer: O) -> Self

Install a telemetry observer. Defaults to NoopObserver if unset.

pub fn observer_arc(self, observer: Arc<dyn Observer>) -> Self

Install a pre-shared observer (when the host already holds an Arc).

pub fn authenticator<A: StreamAuthenticator>(self, auth: A) -> Self

Install a stream authenticator. Defaults to AllowAll if unset.

pub fn authenticator_arc(self, auth: Arc<dyn StreamAuthenticator>) -> Self

Install a pre-shared authenticator (when the host already holds an Arc).

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

Set the idle timeout after which frame-less streams are reaped.

pub fn build(self) -> Arc<Engine>

Build the engine.

Trait Implementations

impl Default for EngineBuilder

fn default() -> Self

Returns the “default value” for a type.