Struct AppState 

pub struct AppState { /* private fields */ }

Shared application state accessible from all handlers via Axum State extractor.

Holds:

• VastarRuntimeWorld for process registration and IPC
• ExchangeHeap for zero-copy SHM allocation
• VilMetrics for Prometheus metrics
• ProcessRegistry for handler process isolation
• HandlerMetricsRegistry for per-route auto-observability

Implementations

impl AppState

pub fn new(name: impl Into<String>) -> Self

pub fn new_shared(name: impl Into<String>) -> Result<Self, String>

Create AppState with a shared (SHM-backed) runtime. This enables cross-process zero-copy communication.

pub fn uptime_secs(&self) -> u64

Get server uptime in seconds

pub fn metrics(&self) -> &VilMetrics

Get VIL metrics collector

pub fn runtime(&self) -> &Arc<VastarRuntimeWorld>

Get the VIL runtime

pub fn shm(&self) -> &Arc<ExchangeHeap>

Get the SHM exchange heap

pub fn shm_pool(&self) -> &Arc<ShmPool>

Get the pre-allocated SHM pool (for ShmSlice, high-performance path)

pub fn process_registry(&self) -> &Arc<ProcessRegistry>

Get the process registry (handler → VIL process mapping)

pub fn handler_metrics(&self) -> &Arc<HandlerMetricsRegistry>

Get per-handler metrics registry (zero-instrumentation observability)

pub fn capsule_registry(&self) -> &Arc<CapsuleRegistry>

Get WASM capsule handler registry

pub fn span_collector(&self) -> &Arc<SpanCollector>

Get OpenTelemetry span collector

pub fn custom_metrics(&self) -> &Arc<CustomMetrics>

Get custom metrics registry

pub fn error_tracker(&self) -> &Arc<ErrorTracker>

Get error tracker

pub fn profiler(&self) -> &Arc<ServerProfiler>

Get server profiler

pub fn config_reloader(&self) -> &Arc<ConfigReloader>

Get config reloader

pub fn plugin_manager(&self) -> &Arc<PluginManager>

Get plugin manager

pub fn upstream_registry(&self) -> &Arc<UpstreamRegistry>

Get upstream metrics registry

pub fn name(&self) -> &str

Get server name

pub fn version(&self) -> &str

Get server version

pub fn request_start(&self)

Record request start for metrics

pub fn request_end(&self, duration_ms: u64)

Record request end with duration for metrics

pub fn upstream_error(&self)

Record an upstream error

pub fn route_error(&self)

Record a route error

pub fn sync_metrics(&self)

Sync metrics from runtime counters (for /metrics endpoint)

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 FromRequest<AppState> for ShmSlice

type Rejection = ShmSliceRejection

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

fn from_request<'life0, 'async_trait>( req: Request, state: &'life0 AppState, ) -> Pin<Box<dyn Future<Output = Result<Self, Self::Rejection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform the extraction.

impl FromRequestParts<AppState> for RequestId

type Rejection = Infallible

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

fn from_request_parts<'life0, 'life1, 'async_trait>( parts: &'life0 mut Parts, _state: &'life1 AppState, ) -> Pin<Box<dyn Future<Output = Result<Self, Self::Rejection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Perform the extraction.

impl FromRequestParts<AppState> for ServiceCtx

type Rejection = VilError

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

fn from_request_parts<'life0, 'life1, 'async_trait>( parts: &'life0 mut Parts, _state: &'life1 AppState, ) -> Pin<Box<dyn Future<Output = Result<Self, Self::Rejection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Perform the extraction.

impl FromRequestParts<AppState> for ShmContext

type Rejection = Infallible

If the extractor fails it’ll use this “rejection” type. A rejection is a kind of error that can be converted into a response.

fn from_request_parts<'life0, 'life1, 'async_trait>( _parts: &'life0 mut Parts, state: &'life1 AppState, ) -> Pin<Box<dyn Future<Output = Result<Self, Self::Rejection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Perform the extraction.