Struct ApplicationState 

pub struct ApplicationState {
    pub Configuration: Arc<AirConfiguration>,
    pub ServiceStatus: Arc<RwLock<HashMap<String, ServiceStatus>>>,
    pub ActiveRequests: Arc<Mutex<HashMap<String, RequestStatus>>>,
    pub Metrics: Arc<RwLock<PerformanceMetrics>>,
    pub Resources: Arc<RwLock<ResourceUsage>>,
    pub Connections: Arc<RwLock<HashMap<String, ConnectionInfo>>>,
    pub BackgroundTasks: Arc<Mutex<Vec<JoinHandle<()>>>>,
}

Application state structure

Fields

Configuration: Arc<AirConfiguration>

Current configuration

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

Service status tracking

ActiveRequests: Arc<Mutex<HashMap<String, RequestStatus>>>

Active requests tracking

Metrics: Arc<RwLock<PerformanceMetrics>>

Performance metrics

Resources: Arc<RwLock<ResourceUsage>>

Resource usage tracking

Connections: Arc<RwLock<HashMap<String, ConnectionInfo>>>

Connection tracking for Mountain clients

BackgroundTasks: Arc<Mutex<Vec<JoinHandle<()>>>>

Background task management

Implementations

impl ApplicationState

pub async fn New(Configuration: Arc<AirConfiguration>) -> Result<Self>

Create a new ApplicationState instance

pub async fn RegisterConnection( &self, ConnectionId: String, ClientId: String, ClientVersion: String, ProtocolVersion: u32, ConnectionType: ConnectionType, ) -> Result<()>

Register a new connection with comprehensive validation Supports connection pooling for Mountain clients

pub async fn UpdateHeartbeat(&self, ConnectionId: &str) -> Result<()>

Update connection heartbeat with validation Validates heartbeat timing and connection state

pub async fn RemoveConnection(&self, ConnectionId: &str) -> Result<()>

Remove connection with proper cleanup and validation Ensures all resources associated with the connection are cleaned up

pub async fn GetActiveConnectionCount(&self) -> usize

Get active connection count with optional filtering by type

pub async fn GetConnectionCountByType( &self, ConnectionType: ConnectionType, ) -> usize

Get connection count by type

pub async fn GetConnectionsByType( &self, ConnectionType: ConnectionType, ) -> Vec<ConnectionInfo>

Get connections by type

pub async fn GetNextMountainConnection(&self) -> Result<ConnectionInfo>

Get connection for load balancing from Mountain pool Implements simple round-robin selection for connection pooling

pub async fn CleanupStaleConnections( &self, TimeoutSeconds: u64, ) -> Result<usize>

Clean up stale connections with comprehensive tracking Removes connections that haven’t sent a heartbeat within the timeout period

pub async fn RegisterBackgroundTask(&self, Task: JoinHandle<()>) -> Result<()>

Register background task with tracking

pub async fn StopAllBackgroundTasks(&self) -> Result<()>

Stop all background tasks with graceful shutdown

pub async fn UpdateServiceStatus( &self, Service: &str, Status: ServiceStatus, ) -> Result<()>

Update service status with validation

pub async fn GetServiceStatus(&self, Service: &str) -> Option<ServiceStatus>

Get service status

pub async fn GetAllServiceStatuses(&self) -> HashMap<String, ServiceStatus>

Get all service statuses

pub async fn RegisterRequest( &self, RequestId: String, Service: String, ) -> Result<()>

Register a new request with validation

pub async fn UpdateRequestStatus( &self, RequestId: &str, Status: RequestState, Progress: Option<f32>, ) -> Result<()>

Update request status with validation

pub async fn RemoveRequest(&self, RequestId: &str) -> Result<()>

Remove completed request with validation

pub async fn UpdateMetrics( &self, Success: bool, ResponseTime: u64, ) -> Result<()>

Update performance metrics with validation

pub async fn UpdateResourceUsage(&self) -> Result<()>

Update resource usage with error handling

pub async fn GetMetrics(&self) -> PerformanceMetrics

Get performance metrics

pub async fn GetResourceUsage(&self) -> ResourceUsage

Get resource usage

pub async fn GetActiveRequestCount(&self) -> usize

Get active request count

pub async fn IsRequestCancelled(&self, RequestId: &str) -> bool

Check if a request is cancelled

pub async fn GetConfiguration(&self) -> Arc<AirConfiguration>

Get current configuration

pub async fn UpdateConfiguration( &self, Section: String, Updates: HashMap<String, String>, ) -> Result<()>

Update configuration with validation and atomic operations

pub async fn SetResourceLimits( &self, MemoryLimitMb: Option<u64>, CPULimitPercent: Option<f64>, DiskLimitMb: Option<u64>, ) -> Result<()>

Set resource limits with validation and enforcement

pub async fn CheckResourceLimits(&self) -> Result<bool>

Check if resource limits are exceeded

pub async fn GetConnectionHealthReport(&self) -> ConnectionHealthReport

Get connection health report

Trait Implementations

impl Debug for ApplicationState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.