Struct AppState 

pub struct AppState {

    pub run_manager: SessionManager,
    pub session_store: Arc<dyn SessionStorage>,
    pub events: Arc<EventLog>,
    pub idempotency: Arc<IdempotencyStore>,
    pub inference: Arc<Inference>,
    pub checkpoint_store: Arc<CheckpointStore>,
    pub models: Arc<Vec<Model>>,
    pub default_model: Option<Model>,
    pub tool_approval_policy: ToolApprovalPolicy,
    pub started_at: Instant,
    pub mcp_client: Option<Arc<McpClient>>,
    pub mcp_tools: Arc<RwLock<Vec<Tool>>>,
    pub mcp_server_shutdown_tx: Option<Sender<()>>,
    pub mcp_proxy_shutdown_tx: Option<Sender<()>>,
    pub sandbox_config: Option<SandboxConfig>,
    /* private fields */
}

Fields

run_manager: SessionManager

session_store: Arc<dyn SessionStorage>

Durable session/checkpoint backend (SQLite/remote API).

events: Arc<EventLog>

idempotency: Arc<IdempotencyStore>

inference: Arc<Inference>

checkpoint_store: Arc<CheckpointStore>

Server-side latest-envelope cache (stakai::Message + runtime metadata).

models: Arc<Vec<Model>>

default_model: Option<Model>

tool_approval_policy: ToolApprovalPolicy

started_at: Instant

mcp_client: Option<Arc<McpClient>>

mcp_tools: Arc<RwLock<Vec<Tool>>>

mcp_server_shutdown_tx: Option<Sender<()>>

mcp_proxy_shutdown_tx: Option<Sender<()>>

sandbox_config: Option<SandboxConfig>

Implementations

impl AppState

pub fn new( session_store: Arc<dyn SessionStorage>, events: Arc<EventLog>, idempotency: Arc<IdempotencyStore>, inference: Arc<Inference>, models: Vec<Model>, default_model: Option<Model>, tool_approval_policy: ToolApprovalPolicy, ) -> Self

pub fn with_mcp( self, mcp_client: Arc<McpClient>, mcp_tools: Vec<Tool>, mcp_server_shutdown_tx: Option<Sender<()>>, mcp_proxy_shutdown_tx: Option<Sender<()>>, ) -> Self

pub fn with_sandbox(self, sandbox_config: SandboxConfig) -> Self

pub fn with_checkpoint_store( self, checkpoint_store: Arc<CheckpointStore>, ) -> Self

pub async fn current_mcp_tools(&self) -> Vec<Tool>

pub async fn refresh_mcp_tools(&self) -> Result<usize, String>

pub fn uptime_seconds(&self) -> u64

pub fn resolve_model(&self, requested: Option<&str>) -> Option<Model>

pub async fn set_pending_tools( &self, session_id: Uuid, run_id: Uuid, tool_calls: Vec<ProposedToolCall>, )

pub async fn clear_pending_tools(&self, session_id: Uuid, run_id: Uuid)

pub async fn pending_tools( &self, session_id: Uuid, ) -> Option<PendingToolApprovals>

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.