Struct AppState 

pub struct AppState { /* private fields */ }

Implementations

impl AppState

pub fn new_single( uri: String, db: Omnigraph, bearer_tokens: Vec<(String, String)>, policy_engine: Option<PolicyEngine>, workload: WorkloadController, ) -> Self

Canonical single-mode constructor. Every other new_* / open_* helper is a thin convenience wrapper around this one. Builds the engine + per-graph policy through build_single_mode, which applies Omnigraph::with_policy so HTTP-layer and engine-layer policy can never diverge — there is no “policy installed on HTTP but not on engine” representable state (closes the prior with_policy_engine footgun that reused the engine Arc without re-applying with_policy).

pub fn new(uri: String, db: Omnigraph) -> Self

pub fn new_with_bearer_token( uri: String, db: Omnigraph, bearer_token: Option<String>, ) -> Self

pub fn new_with_bearer_tokens( uri: String, db: Omnigraph, bearer_tokens: Vec<(String, String)>, ) -> Self

pub fn new_with_bearer_tokens_and_policy( uri: String, db: Omnigraph, bearer_tokens: Vec<(String, String)>, policy_engine: Option<PolicyEngine>, ) -> Self

pub fn new_with_workload( uri: String, db: Omnigraph, bearer_tokens: Vec<(String, String)>, workload: WorkloadController, ) -> Self

Construct with a caller-provided workload::WorkloadController. Tests and benches use this to override per-actor caps without mutating global env vars (unsafe in Rust 2024 once the async runtime is up — setenv isn’t thread-safe). For tests that also need a custom PolicyEngine, use [new_single] directly.

pub async fn open(uri: impl Into<String>) -> Result<Self>

pub async fn open_with_bearer_token( uri: impl Into<String>, bearer_token: Option<String>, ) -> Result<Self>

pub async fn open_with_bearer_tokens( uri: impl Into<String>, bearer_tokens: Vec<(String, String)>, ) -> Result<Self>

pub async fn open_with_bearer_tokens_and_policy( uri: impl Into<String>, bearer_tokens: Vec<(String, String)>, policy_file: Option<&PathBuf>, ) -> Result<Self>

pub async fn open_single_with_queries( uri: impl Into<String>, bearer_tokens: Vec<(String, String)>, policy_file: Option<&PathBuf>, queries: QueryRegistry, ) -> Result<Self>

Single-mode boot with a stored-query registry: open the engine, type-check the registry against the live schema and refuse to start on a breakage (same posture as bad policy YAML), log non-blocking warnings, then attach the registry to the handle. With an empty registry the check is a no-op and no registry is attached — that is the path open_with_bearer_tokens_and_policy (no stored queries) takes.

pub fn new_multi( handles: Vec<Arc<GraphHandle>>, bearer_tokens: Vec<(String, String)>, server_policy: Option<PolicyEngine>, workload: WorkloadController, config_path: Option<PathBuf>, ) -> Result<Self, InsertError>

Multi-mode constructor — used by the startup loop. Operators reach this by invoking omnigraph-server --config omnigraph.yaml with a non-empty graphs: map.

Caller supplies the already-opened GraphHandles and (optionally) the path to the source config file. server_policy is loaded from server.policy.file if configured.

pub fn routing(&self) -> &GraphRouting

Runtime routing accessor. Handlers don’t typically inspect this — they extract Arc<GraphHandle> via the routing middleware — but build_app matches on it to decide flat vs nested route mounting, and a handful of management endpoints (GET /graphs, the OpenAPI cluster rewrite) match on the discriminant.

Trait Implementations

impl Clone for AppState

fn clone(&self) -> AppState

Returns a duplicate of the value.

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

Performs copy-assignment from source.