Struct HttpState 

pub struct HttpState {
    pub rag: Arc<RAGPipeline>,
    pub mcp_core: Arc<McpCore>,
    pub mcp_sessions: Arc<McpSessionManager>,
    pub mcp_base_url: Arc<RwLock<String>>,
    pub cached_namespaces: Arc<RwLock<Option<Vec<NamespaceInfo>>>>,
    pub namespace_activity: Arc<RwLock<HashMap<String, String>>>,
    pub last_successful_append_at: Arc<RwLock<Option<String>>>,
    pub diagnostic_dry_run_approvals: Arc<RwLock<HashMap<String, Instant>>>,
    pub auth_token: Option<String>,
    pub auth_mode: AuthMode,
    pub allow_query_token: bool,
    pub auth_manager: Option<Arc<AuthManager>>,
    /* private fields */
}

Shared state for HTTP handlers - reuses the same MCP core and storage runtime as stdio/SSE.

Fields

rag: Arc<RAGPipeline>

mcp_core: Arc<McpCore>

Shared MCP protocol core reused by stdio and HTTP/SSE transports

mcp_sessions: Arc<McpSessionManager>

MCP session manager for SSE transport

mcp_base_url: Arc<RwLock<String>>

Base URL for MCP messages endpoint (set at startup)

cached_namespaces: Arc<RwLock<Option<Vec<NamespaceInfo>>>>

Cached namespace list (refreshed in background for large DBs)

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

Per-namespace last activity timestamp (updated on upsert/index)

last_successful_append_at: Arc<RwLock<Option<String>>>

Last successful append timestamp across all HTTP write paths.

diagnostic_dry_run_approvals: Arc<RwLock<HashMap<String, Instant>>>

Recent destructive diagnostic dry-runs approved for follow-up execute calls.

auth_token: Option<String>

Optional Bearer token for authenticating mutating requests

auth_mode: AuthMode

Auth enforcement mode

allow_query_token: bool

Allow ?token= query parameter on read GETs

auth_manager: Option<Arc<AuthManager>>

Multi-token auth manager (Track C). Used when auth_mode == NamespaceAcl.

Implementations

impl HttpState

pub fn new(rag: Arc<RAGPipeline>, mcp_core: Arc<McpCore>) -> Self

Trait Implementations

impl Clone for HttpState

fn clone(&self) -> HttpState

Returns a duplicate of the value.

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

Performs copy-assignment from source.