Struct HealthCheckManager 

pub struct HealthCheckManager {
    ServiceHealth: Arc<RwLock<HashMap<String, ServiceHealth>>>,
    HealthHistory: Arc<RwLock<Vec<HealthCheckRecord>>>,
    RecoveryActions: Arc<RwLock<HashMap<String, RecoveryAction>>>,
    config: HealthCheckConfig,
}

Health check manager

Fields

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

Service health status

HealthHistory: Arc<RwLock<Vec<HealthCheckRecord>>>

Health check history

RecoveryActions: Arc<RwLock<HashMap<String, RecoveryAction>>>

Recovery actions

config: HealthCheckConfig

Health check configuration

Implementations

impl HealthCheckManager

pub fn new(config: Option<HealthCheckConfig>) -> Self

Create a new HealthCheckManager instance

pub async fn RegisterService( &self, ServiceName: String, CheckLevel: HealthCheckLevel, ) -> Result<()>

Register a service for health monitoring

pub async fn CheckService(&self, ServiceName: &str) -> Result<HealthStatus>

Perform health check for a service

async fn CheckAuthenticationService(&self) -> (HealthStatus, Option<String>)

Check authentication service health

async fn CheckUpdatesService(&self) -> (HealthStatus, Option<String>)

Check updates service health

async fn CheckDownloaderService(&self) -> (HealthStatus, Option<String>)

Check downloader service health

async fn CheckIndexingService(&self) -> (HealthStatus, Option<String>)

Check indexing service health

async fn CheckgRPCService(&self) -> (HealthStatus, Option<String>)

Check gRPC service health

async fn CheckConnectionsService(&self) -> (HealthStatus, Option<String>)

Check connections service health

async fn UpdateServiceHealth( &self, ServiceName: &str, status: HealthStatus, ErrorMessage: &Option<String>, ResponseTime: u64, ) -> Result<()>

Update service health status

async fn RecordHealthCheck( &self, ServiceName: &str, status: HealthStatus, ResponseTime: u64, ErrorMessage: &Option<String>, )

Record health check in history

async fn TriggerRecoveryIfNeeded(&self, ServiceName: &str)

Trigger recovery actions if needed

async fn HandleResponseTimeRecovery(&self, ServiceName: &str, ResponseTime: u64)

Handle response time-based recovery

async fn HandleCriticalAlerts(&self, ServiceName: &str, status: &HealthStatus)

Handle critical health alerts

async fn PerformRecoveryAction(&self, ServiceName: &str)

Perform recovery action for a service

async fn RestartAuthenticationService(&self) -> Result<()>

Restart authentication service

async fn RestartUpdatesService(&self) -> Result<()>

Restart updates service

async fn RestartDownloaderService(&self) -> Result<()>

Restart downloader service

async fn RestartIndexingService(&self) -> Result<()>

Restart indexing service

async fn RestartgRPCService(&self) -> Result<()>

Restart gRPC service

async fn ResetConnectionsService(&self) -> Result<()>

Reset connections service

pub async fn GetOverallHealth(&self) -> HealthStatus

Get overall daemon health status

pub async fn GetServiceHealth( &self, service_name: &str, ) -> Option<ServiceHealth>

Get service health status

pub async fn GetHealthHistory( &self, service_name: Option<&str>, limit: Option<usize>, ) -> Vec<HealthCheckRecord>

Get health check history

pub async fn RegisterRecoveryAction(&self, action: RecoveryAction) -> Result<()>

Register a recovery action

pub async fn GetHealthStatistics(&self) -> HealthStatistics

Get health statistics

Trait Implementations

impl Debug for HealthCheckManager

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

Formats the value using the given formatter.