Struct ServerState 

pub struct ServerState {
    pub sites: HashMap<String, SiteBackend>,
    pub console_inactivity_timeout: Duration,
    pub auditor: Option<Kafka>,
    pub auth_rate_limit_per_minute: Option<u32>,
}

Shared state for all HTTP handlers.

Holds one SiteBackend per configured site so that the server can serve multiple clusters. Each request supplies the target site via the X-Manta-Site header; handlers call ServerState::infra_context to retrieve the per-site data.

Fields

sites: HashMap<String, SiteBackend>

Per-site connection data, keyed by site name.

console_inactivity_timeout: Duration

How long a WebSocket console session may be idle before the server closes it. Protects against leaked Kubernetes pod attachments.

auditor: Option<Kafka>

Kafka producer for security/audit events (currently used only by /api/v1/auth/*). None disables audit emission.

auth_rate_limit_per_minute: Option<u32>

Per-source-IP rate limit on /api/v1/auth/* (requests/minute). None disables in-process rate limiting.

Implementations

impl ServerState

pub fn infra_context<'a>( &'a self, site_name: &'a str, ) -> Result<InfraContext<'a>, Error>

Build a borrowed InfraContext for the named site.

Returns Err(Error::NotFound) when site_name is not in the map. Called per-request so the service layer can work with its existing &InfraContext<'_> API.