Struct RuntimeBuilder 

pub struct RuntimeBuilder { /* private fields */ }

Implementations

impl RuntimeBuilder

pub fn acquisition_source( self, source: Arc<dyn AcquisitionSource>, max_concurrency: usize, ) -> Self

Install a source by its spec 032 descriptor with a per-source attempt bound.

pub fn backend( self, backend: Arc<dyn DecisionBackend>, max_concurrency: usize, ) -> Self

Register a backend with its own attempt concurrency limit.

pub fn host_backend( self, backend: Arc<dyn DecisionBackend>, max_concurrency: usize, ) -> Self

Register a backend the host implements itself (spec 033, 3.9.1): its failures are caused by the host, not an upstream service. A host relaying a failure from its own upstream may still report it as upstream; nothing reports the caller.

pub fn shared_ledger(self, ledger: Arc<Ledger>) -> Self

A ledger shared by every decision, reserved after each decision’s own.

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

Build the runtime. Under a queued sink policy this spawns the delivery worker, so it must run inside a Tokio runtime.