Struct AppState 

pub struct AppState {
    pub config: ConsoleConfig,
    pub ws_connections: Arc<RwLock<HashMap<String, usize>>>,
    pub rate_limiter: Arc<RwLock<HashMap<String, (u32, Instant)>>>,
    pub sessions: Arc<RwLock<HashMap<String, String>>>,
    pub metrics_cache: Arc<RwLock<Option<DashboardMetrics>>>,
}

Shared application state

Fields

config: ConsoleConfig

Configuration

ws_connections: Arc<RwLock<HashMap<String, usize>>>

Active WebSocket connections (user_id -> connection count)

rate_limiter: Arc<RwLock<HashMap<String, (u32, Instant)>>>

Rate limiter state (user_id -> request count)

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

Session store (session_id -> user_id)

metrics_cache: Arc<RwLock<Option<DashboardMetrics>>>

Cached metrics for dashboard

Implementations

impl AppState

pub async fn new(config: &ConsoleConfig) -> Result<Self>

Create new application state

pub async fn can_create_ws_connection(&self, user_id: &str) -> bool

Check if user can create a new WebSocket connection

pub async fn increment_ws_connection(&self, user_id: String)

Increment WebSocket connection count for user

pub async fn decrement_ws_connection(&self, user_id: &str)

Decrement WebSocket connection count for user

pub async fn check_rate_limit(&self, user_id: &str) -> Result<()>

Check rate limit for user

pub async fn store_session(&self, session_id: String, user_id: String)

Store session

pub async fn get_session(&self, session_id: &str) -> Option<String>

Get user ID from session

pub async fn remove_session(&self, session_id: &str)

Remove session

pub async fn update_metrics(&self, metrics: DashboardMetrics)

Update metrics cache

pub async fn get_metrics(&self) -> Option<DashboardMetrics>

Get cached metrics