Struct AppState 

pub struct AppState<S: Storage, P: Provider> {
    pub registry: Arc<ArcSwap<ProviderRegistry<P>>>,
    pub config: GatewayConfig,
    pub extensions: Arc<Vec<Box<dyn Extension>>>,
    pub storage: Arc<S>,
    pub key_map: Arc<RwLock<HashMap<String, String>>>,
    pub usage_events: Option<Sender<UsageEvent>>,
}

Shared application state passed to all handlers.

Generic over the storage backend S and the provider type P. The binary picks P by defining a workspace-level union enum that wraps every provider source it links — that enum implements Provider via match-and-delegate, so dispatch through P is fully monomorphized.

Fields

registry: Arc<ArcSwap<ProviderRegistry<P>>>

config: GatewayConfig

extensions: Arc<Vec<Box<dyn Extension>>>

storage: Arc<S>

key_map: Arc<RwLock<HashMap<String, String>>>

Precomputed token → key name lookup for O(1) auth. Wrapped in RwLock to support runtime key management.

usage_events: Option<Sender<UsageEvent>>

Optional broadcast sink for per-request UsageEvents. None is a no-op — the standalone crabllm serve binary leaves it unset and behavior is unchanged. Embedders that want live traffic construct a sender, pass Some(sender.clone()), and call sender.subscribe() to observe events.

Implementations

impl<S: Storage, P: Provider> AppState<S, P>

pub fn registry(&self) -> Guard<Arc<ProviderRegistry<P>>>

Snapshot the current provider registry. Returns a guard that keeps the referenced registry alive for the duration of the request — even if a concurrent swap replaces the global pointer.

Trait Implementations

impl<S: Storage, P: Provider> Clone for AppState<S, P>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.