Struct StatusReporter 

pub struct StatusReporter {
    runtime: Arc<ApplicationRunTime>,
    ipc_server: Option<Arc<TauriIPCServer>>,
    status_history: Arc<Mutex<Vec<IPCStatusReport>>>,
    start_time: SystemTime,
    error_count: Arc<Mutex<u32>>,
    performance_metrics: Arc<Mutex<PerformanceMetrics>>,
    health_monitor: Arc<Mutex<HealthMonitor>>,
    service_registry: Arc<RwLock<ServiceRegistry>>,
    discovered_services: Arc<RwLock<HashSet<String>>>,
}

Status reporter for IPC communication

Fields

runtime: Arc<ApplicationRunTime>

ipc_server: Option<Arc<TauriIPCServer>>

status_history: Arc<Mutex<Vec<IPCStatusReport>>>

start_time: SystemTime

error_count: Arc<Mutex<u32>>

performance_metrics: Arc<Mutex<PerformanceMetrics>>

health_monitor: Arc<Mutex<HealthMonitor>>

service_registry: Arc<RwLock<ServiceRegistry>>

discovered_services: Arc<RwLock<HashSet<String>>>

Implementations

impl StatusReporter

pub fn new(runtime: Arc<ApplicationRunTime>) -> Self

Create a new status reporter

pub fn set_ipc_server(&mut self, ipc_server: Arc<TauriIPCServer>)

Set the IPC server instance

pub async fn generate_status_report(&self) -> Result<IPCStatusReport, String>

Generate a status report

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

STATUS REPORTING: Microsoft-inspired comprehensive reporting

pub async fn start_periodic_reporting( &self, interval_seconds: u64, ) -> Result<(), String>

Start periodic status reporting

pub fn record_error(&self)

Record an error

pub fn get_status_history(&self) -> Result<Vec<IPCStatusReport>, String>

Get status history

pub fn get_start_time(&self) -> SystemTime

Get the start time

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

PERFORMANCE MONITORING: Microsoft-inspired performance tracking

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

HEALTH MONITORING: Microsoft-inspired health checks

async fn calculate_message_rate(&self) -> f64

METRICS CALCULATION: Microsoft-inspired performance algorithms

async fn calculate_average_latency(&self) -> f64

async fn calculate_peak_latency(&self) -> f64

async fn calculate_compression_ratio(&self) -> f64

async fn calculate_pool_utilization(&self, stats: &ConnectionStats) -> f64

async fn get_memory_usage(&self) -> f64

async fn get_cpu_usage(&self) -> f64

pub async fn discover_services(&self) -> Result<Vec<ServiceInfo>, String>

SERVICE DISCOVERY: Discover available Mountain services

fn get_service_dependencies(&self, service_name: &str) -> Vec<String>

Get service dependencies

async fn calculate_service_response_time(&self, service_name: &str) -> f64

Calculate service response time

async fn calculate_service_error_rate(&self, service_name: &str) -> f64

Calculate service error rate

async fn calculate_service_throughput(&self, service_name: &str) -> f64

Calculate service throughput

async fn get_service_memory_usage(&self, service_name: &str) -> f64

Get service memory usage

async fn get_service_cpu_usage(&self, service_name: &str) -> f64

Get service CPU usage

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

Start periodic service discovery

pub async fn get_service_registry(&self) -> Result<ServiceRegistry, String>

Get service registry

pub async fn get_service_info( &self, service_name: &str, ) -> Result<Option<ServiceInfo>, String>

Get service information

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

RECOVERY: Microsoft-inspired automatic recovery

pub fn get_performance_metrics(&self) -> Result<PerformanceMetrics, String>

Get performance metrics

pub fn get_health_status(&self) -> Result<HealthMonitor, String>

Get health status

fn clone_reporter(&self) -> StatusReporter

Clone the reporter for async tasks