WorkflowForge.Extensions.Observability.HealthChecks

Comprehensive health monitoring extension for WorkflowForge applications with built-in and custom health checks.

Installation

dotnet add package WorkflowForge.Extensions.Observability.HealthChecks

Quick Start

using WorkflowForge.Extensions.Observability.HealthChecks; // Create foundry and create a health check service using var foundry = WorkflowForge.CreateFoundry("MyWorkflow"); var healthService = foundry.CreateHealthCheckService(TimeSpan.FromSeconds(30)); // Execute health checks var results = await healthService.CheckHealthAsync(); Console.WriteLine($"Overall Status: {healthService.OverallStatus}"); foreach (var (name, result) in results) { Console.WriteLine($"{name}: {result.Status} - {result.Description}"); }

Key Features

• Built-in Health Checks: Memory, garbage collection, thread pool monitoring
• Custom Health Checks: Easy interface for application-specific checks
• Periodic Monitoring: Optional background health check execution
• Foundry Integration: Seamless foundry health monitoring
• Detailed Reporting: Rich health check results with performance data

Built-in Health Checks

System Health Monitoring

// Automatically included when using CreateHealthCheckService(): // - Memory Health Check (working set, managed memory) // - Garbage Collector Health Check (GC performance) // - Thread Pool Health Check (thread availability) var overallStatus = await foundry.CheckFoundryHealthAsync(healthService);

Custom Health Checks

public class DatabaseHealthCheck : IHealthCheck { public string Name => "Database"; public string Description => "Checks database connectivity"; public async Task<HealthCheckResult> CheckHealthAsync(CancellationToken cancellationToken = default) { try { await _connection.OpenAsync(cancellationToken); return HealthCheckResult.Healthy("Database connection successful"); } catch (Exception ex) { return HealthCheckResult.Unhealthy("Database connection failed", ex); } } } // Register custom health check healthService.RegisterHealthCheck(new DatabaseHealthCheck(dbConnection));