pub struct RuntimeConfig {Show 27 fields
pub listen: ListenConfig,
pub tls: Option<TlsConfig>,
pub auth: AuthConfig,
pub ops_console: OpsConsoleConfig,
pub namespace: NamespaceConfig,
pub worker: WorkerConfig,
pub websocket: WebSocketConfig,
pub workflow_packages: Vec<PathBuf>,
pub deploy: DeployConfig,
pub authoring: AuthoringConfig,
pub dev: DevConfig,
pub outbox: OutboxConfig,
pub observability: ObservabilityConfig,
pub mcp: ResolvedMcpConfig,
pub assistant: ResolvedAssistantConfig,
pub scheduler_threads: usize,
pub jit_threshold: Option<u32>,
pub query_timeout: Option<Duration>,
pub workloop_sweep_interval: Option<Duration>,
pub stop_drain_timeout: Option<Duration>,
pub default_namespace: String,
pub auto_create: AutoCreate,
pub max_in_flight_activities: u32,
pub drain_timeout: Duration,
pub metrics: MetricsConfig,
pub owned_shards: Vec<usize>,
pub cors_allowed_origins: Vec<String>,
}Expand description
Runtime settings retained in shared server state for transport adapters.
Fields§
§listen: ListenConfigListener addresses for public transports.
tls: Option<TlsConfig>Optional TLS material for public transports.
auth: AuthConfigAuthentication configuration shared by transports.
ops_console: OpsConsoleConfigOps-console asset location.
namespace: NamespaceConfigNamespace resolver construction mode.
worker: WorkerConfigRemote worker heartbeat configuration.
websocket: WebSocketConfigWebSocket stream configuration.
workflow_packages: Vec<PathBuf>Workflow package archives loaded into the engine at startup.
deploy: DeployConfigOperator deploy API settings.
Server-side Gleam authoring API settings.
dev: DevConfigLocal dev-server surface settings.
outbox: OutboxConfigDurable-outbox fan-out dispatcher settings.
observability: ObservabilityConfigAgent-observability transcript retention bounds ([observability]).
mcp: ResolvedMcpConfigModel Context Protocol surface settings ([mcp]), fully resolved.
assistant: ResolvedAssistantConfigAssistant-session settings ([assistant]), fully resolved. The
Default is the STOCK form — no [assistant] section, so no declared
account — which is what a server whose config never mentions the surface
carries, and which still serves the assistant on every harness the
catalogue ships.
scheduler_threads: usizeEngine scheduler thread count.
jit_threshold: Option<u32>Engine JIT compilation threshold, or None to defer to beamr’s own
default. Carried as an Option because “the operator named a
threshold” and “nobody said” are different states, and only the first
may override beamr.
query_timeout: Option<Duration>Engine reply deadline for workflow queries. REQUIRED — carried as an
Option only so state construction can re-validate (defense in
depth, like websocket.event_broadcast_capacity); validated
configurations always hold Some non-zero duration.
workloop_sweep_interval: Option<Duration>Workloop sweep interval — how often the engine checks its registered loops for a due cadence window or an exceeded tolerance.
stop_drain_timeout: Option<Duration>The engine stop’s NO-PROGRESS drain bound (AE-017), from
[runtime].stop_drain_timeout_ms. Carried as an Option like
query_timeout so state construction can re-validate; validated
configurations always hold Some non-zero duration.
default_namespace: StringDefault namespace used by worker dispatch and unauthenticated local callers.
auto_create: AutoCreateMinted-on-use policy applied at the worker-registration mint hook
([namespaces] auto_create). AutoCreate::Open (the default) mints an
unseen namespace durably; AutoCreate::Closed rejects it.
max_in_flight_activities: u32Platform-wide default for a namespace’s cluster-wide concurrent
in-flight-activity ceiling ([namespaces] max_in_flight_activities),
applied when a namespace record carries no explicit override. Carried in
runtime state so the later P2-Q2 keyed-backpressure dispatcher can read
it without reloading config. Stored-only in this slice — nothing reads it
yet.
drain_timeout: DurationGraceful drain timeout.
metrics: MetricsConfigMetrics endpoint settings.
owned_shards: Vec<usize>Static distribution-shard assignment for this node (from [store] owned_shards). Empty means own ALL shards (single-node default,
byte-identical to today); a non-empty set scopes engine recovery and
enumeration to exactly those shards. No election: assignment is static.
cors_allowed_origins: Vec<String>Browser origins allowed cross-origin access to the public HTTP API (from
[server] cors_allowed_origins). Empty means no cross-origin access and
no CorsLayer is installed (secure default); a non-empty set installs
the layer scoped to exactly those origins.
Trait Implementations§
Source§impl Clone for RuntimeConfig
impl Clone for RuntimeConfig
Source§fn clone(&self) -> RuntimeConfig
fn clone(&self) -> RuntimeConfig
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl Freeze for RuntimeConfig
impl RefUnwindSafe for RuntimeConfig
impl Send for RuntimeConfig
impl Sync for RuntimeConfig
impl Unpin for RuntimeConfig
impl UnsafeUnpin for RuntimeConfig
impl UnwindSafe for RuntimeConfig
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoMaybeUndefined<T> for T
impl<T> IntoMaybeUndefined<T> for T
Source§fn into_maybe_undefined(self) -> MaybeUndefined<T>
fn into_maybe_undefined(self) -> MaybeUndefined<T>
Source§impl<T> IntoOption<T> for T
impl<T> IntoOption<T> for T
Source§fn into_option(self) -> Option<T>
fn into_option(self) -> Option<T>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::Request