Struct AdminState 

pub struct AdminState {
    pub node_health: RwLock<HashMap<String, NodeHealth>>,
    pub metrics: RwLock<ServerMetricsSnapshot>,
    pub active_sessions: RwLock<u64>,
    pub config_snapshot: RwLock<ConfigSnapshot>,
    pub proxy_config: RwLock<Option<ProxyConfig>>,
    pub replay_engine: RwLock<Option<Arc<ReplayEngine>>>,
    pub plugin_manager: RwLock<Option<Arc<PluginManager>>>,
    pub chaos_overrides: RwLock<HashMap<String, ChaosOverride>>,
    pub anomaly_detector: RwLock<Option<Arc<AnomalyDetector>>>,
    pub edge_cache: RwLock<Option<Arc<EdgeCache>>>,
    pub edge_registry: RwLock<Option<Arc<EdgeRegistry>>>,
    /* private fields */
}

Shared admin state

Fields

node_health: RwLock<HashMap<String, NodeHealth>>

Node health status

metrics: RwLock<ServerMetricsSnapshot>

Server metrics

active_sessions: RwLock<u64>

Active sessions count

config_snapshot: RwLock<ConfigSnapshot>

Configuration (read-only)

proxy_config: RwLock<Option<ProxyConfig>>

Full proxy config (for SQL routing)

replay_engine: RwLock<Option<Arc<ReplayEngine>>>

Time-travel replay engine. Optional so test fixtures don’t have to wire a backend template; production startup attaches it via with_replay_engine. Endpoint returns 503 when missing.

plugin_manager: RwLock<Option<Arc<PluginManager>>>

WASM plugin manager. None when the proxy started without plugins (or with a different feature set). /plugins endpoint returns 503 when missing; UI panel says “no plugin manager attached”.

chaos_overrides: RwLock<HashMap<String, ChaosOverride>>

Chaos-mode overrides: per-node-address marker that the chaos system (POST /api/chaos) has forced this node to a particular state. Lets the UI distinguish “operationally disabled” from “chaos-injected fault” and lets Reset restore everything.

anomaly_detector: RwLock<Option<Arc<AnomalyDetector>>>

Anomaly detector — same Arc the server populates from the query path. /api/anomalies polls this for the recent-events ring buffer.

edge_cache: RwLock<Option<Arc<EdgeCache>>>

Edge proxy cache + registry. Cache surfaces stats; registry is the home-side fanout for invalidations.

edge_registry: RwLock<Option<Arc<EdgeRegistry>>>

Implementations

impl AdminState

pub fn new() -> Self

Create new admin state

pub async fn with_anomaly_detector(&self, detector: Arc<AnomalyDetector>)

Attach an anomaly detector. Mirror of with_replay_engine / with_plugin_manager — wired by the server at startup.

pub async fn with_edge( &self, cache: Arc<EdgeCache>, registry: Arc<EdgeRegistry>, )

Attach edge cache + registry. Server calls this once at startup; both Arcs are the same instances ServerState holds.

pub async fn with_replay_engine(&self, engine: Arc<ReplayEngine>)

Attach a time-travel replay engine. Production startup calls this once with a ReplayEngine constructed from the proxy’s shared TransactionJournal + a BackendConfig template; the /api/replay endpoint returns 503 until this is set.

pub async fn with_plugin_manager(&self, manager: Arc<PluginManager>)

Attach a WASM plugin manager. Production startup calls this once with the same Arc held by ProxyServer; the /plugins endpoint returns 503 until set.

pub async fn set_proxy_config(&self, config: ProxyConfig)

Set the proxy configuration for SQL routing

pub async fn register_command<F>(&self, name: &str, handler: F)

where F: Fn(&[&str]) -> Result<String> + Send + Sync + 'static,

Register a command handler

pub async fn execute_command(&self, name: &str, args: &[&str]) -> Result<String>

Execute a command

Trait Implementations

impl Default for AdminState

fn default() -> Self

Returns the “default value” for a type.