Struct AppState 

pub struct AppState {

    pub cluster_config: ClusterConfig,
    pub container_runtime: Arc<dyn Runtime>,
    pub wasm_runtime: Option<Arc<dyn Runtime>>,
    pub services: RwLock<HashMap<String, ServiceState>>,
    pub route_table: SharedRouteTable,
    pub wasm_triggers: SharedWasmTriggers,
    pub registered_nodes: RwLock<HashMap<u64, RegisteredNode>>,
    pub webhooks: WebhookStore,
    pub api_tokens: Vec<String>,
    pub pending_commands: RwLock<HashMap<u64, Vec<Value>>>,
    pub deploy_history: RwLock<DeployHistory>,
    pub acme_manager: Option<AcmeManager>,
    pub cert_resolver: Option<SharedCertResolver>,
    pub container_stats: RwLock<HashMap<String, ContainerStats>>,
    pub store: Option<Arc<ClusterStore>>,
    pub ws_agents: RwLock<HashMap<u64, AgentSender>>,
    pub log_listeners: RwLock<HashMap<String, Sender<(String, bool)>>>,
}

Shared state for the control plane, accessible by the API server and reconciler.

Fields

cluster_config: ClusterConfig

Cluster configuration.

container_runtime: Arc<dyn Runtime>

Container runtime (Docker).

wasm_runtime: Option<Arc<dyn Runtime>>

Wasm runtime (wasmtime). Trait object to avoid coupling to concrete type.

services: RwLock<HashMap<String, ServiceState>>

Current service state, keyed by service name.

route_table: SharedRouteTable

Routing table for container workloads, shared with the reverse proxy.

wasm_triggers: SharedWasmTriggers

Wasm HTTP triggers, shared with the reverse proxy.

registered_nodes: RwLock<HashMap<u64, RegisteredNode>>

Registered cluster nodes (M2 in-memory, will move to Raft store).

webhooks: WebhookStore

Webhook configurations for push-triggered deploys.

api_tokens: Vec<String>

API bearer tokens for authentication (empty = allow all).

pending_commands: RwLock<HashMap<u64, Vec<Value>>>

Pending commands for agent nodes, keyed by node_id. Uses serde_json::Value to avoid circular dependency on orca-agent types.

deploy_history: RwLock<DeployHistory>

Deploy history for rollback support.

acme_manager: Option<AcmeManager>

ACME manager for hot cert provisioning (None if no TLS).

cert_resolver: Option<SharedCertResolver>

Dynamic cert resolver shared with the HTTPS listener.

container_stats: RwLock<HashMap<String, ContainerStats>>

Cached container stats, keyed by service name.

store: Option<Arc<ClusterStore>>

Persistent cluster store (redb). None in tests without persistence.

ws_agents: RwLock<HashMap<u64, AgentSender>>

WebSocket senders for connected agent nodes, keyed by node_id.

log_listeners: RwLock<HashMap<String, Sender<(String, bool)>>>

Log stream listeners: request_id → (data, done) sender.

Implementations

impl AppState

pub fn new( cluster_config: ClusterConfig, container_runtime: Arc<dyn Runtime>, wasm_runtime: Option<Arc<dyn Runtime>>, route_table: SharedRouteTable, wasm_triggers: SharedWasmTriggers, ) -> Self

Create with shared route table and Wasm triggers (for sharing with the proxy).

pub fn with_store(self, store: Arc<ClusterStore>) -> Self

Set persistent store for service state.

pub fn with_acme( self, manager: AcmeManager, resolver: SharedCertResolver, ) -> Self

Set ACME manager and cert resolver for hot cert provisioning.