Struct AppState 

pub struct AppState {
    pub functions: Arc<DashMap<Uuid, FunctionRecord>>,
    pub jobs: Arc<DashMap<Uuid, JobRecord>>,
    pub metrics: Arc<TensorWasmMetrics>,
    pub executor: Arc<TensorWasmExecutor>,
    pub kernel_registry: Option<Arc<dyn KernelRegistry>>,
    pub openai_model_map: ModelMap,
    pub app_config: AppConfig,
}

Process-global state shared by every handler.

Arc<AppState> is cloned into the router via with_state; the inner DashMaps sit behind their own Arc so cheap clones of the maps remain possible across the codebase.

Fields

functions: Arc<DashMap<Uuid, FunctionRecord>>

Deployed-function registry, keyed by id.

jobs: Arc<DashMap<Uuid, JobRecord>>

Async-job registry, keyed by id.

metrics: Arc<TensorWasmMetrics>

Shared metrics registry. Cloned into the executor so spawn/terminate counters and the /metrics scrape view the same atomics.

executor: Arc<TensorWasmExecutor>

Wasm executor driving the synchronous /invoke path.

kernel_registry: Option<Arc<dyn KernelRegistry>>

Optional kernel registry (B6.4 / roadmap feature #3). None when TENSOR_WASM_API_KERNEL_HMAC_KEY is unset; the /kernels routes return 503 kernel_registry_not_configured in that case so client tools can detect feature availability without inspecting the URL surface. Only compiled when the kernel-registry-api feature is enabled — the default build keeps the lean dep graph.

openai_model_map: ModelMap

OpenAI model → FunctionId resolution map (T41). Read from TENSOR_WASM_API_OPENAI_MODEL_MAP at startup; empty map means every OpenAI request returns 404 model_not_found. See crate::openai_translator for the env-var grammar.

app_config: AppConfig

Top-level AppConfig carrying the snapshot HMAC signing key and the require_signature toggle (M5).

Read from the environment (TENSOR_WASM_API_SNAPSHOT_HMAC_KEY / TENSOR_WASM_API_SNAPSHOT_REQUIRE_SIGNATURE) in build_router and threaded here so the /snapshot/save and /snapshot/restore handlers can sign and verify blobs with the operator’s configured key. When the key is None the snapshot routes return 503 snapshot_signing_not_configured — mirroring the kernel-registry posture so a client can detect the feature being disabled without inspecting the URL surface.

Implementations

impl AppState

pub fn with_app_config(self, cfg: AppConfig) -> Self

Install the top-level AppConfig, carrying the snapshot HMAC key + require-signature toggle (M5).

Called by build_router with the result of AppConfig::from_env so the /snapshot/* handlers consume the operator-configured key. Public so integration tests can drive the snapshot routes with an explicit key without poisoning the process environment.

pub fn try_new() -> Result<Arc<Self>, TensorWasmError>

Fallible constructor. Returns a TensorWasmError if the underlying wasmtime engine cannot be initialised (e.g. unsupported strategy on the host). Production callers should use this and surface the failure through their own startup path.

pub fn new() -> Arc<Self>

Construct an AppState wrapped in Arc for use with Router::with_state. Panics on engine initialisation failure.

Prefer AppState::try_new in production code; this convenience wrapper exists for parity with Default and for tests.

pub fn with_metrics(self, metrics: Arc<TensorWasmMetrics>) -> Self

Override the metrics registry, rebuilding the executor so its spawn/terminate counters share the supplied handle.

Useful for tests that need to inspect counter values, or for embedders who construct a process-wide registry separately. Panics on engine initialisation failure for ergonomic parity with Self::new.

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.

impl Debug for AppState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for AppState

fn default() -> Self

Default AppState. Calls the internal builder and unwraps for the same reasons documented on AppState::new: in practice TensorWasmEngine::new only fails on host misconfiguration, which is a fatal startup condition. Used by tests via AppState::default().