ヘルスチェック

// ヘルスチェッカーを作成
checker := health.NewChecker()

// ヘルスチェックエンドポイントをマウント
// サービスステータスを返すGET /healthエンドポイントを作成
mux.Handle("GET", "/health", health.Handler(checker))

{
    "status": {
        "PostgreSQL": "OK",
        "Redis": "OK",
        "PaymentService": "NOT OK"
    },
    "uptime": 3600,
    "version": "1.0.0"
}

// Pingerインターフェース
type Pinger interface {
    Name() string                    // 依存関係の一意の識別子
    Ping(context.Context) error      // 依存関係が正常かチェック
}

// データベースのヘルスチェック
// PostgreSQLデータベースの実装例
type DBClient struct {
    db *sql.DB
}

func (c *DBClient) Name() string {
    return "PostgreSQL"
}

func (c *DBClient) Ping(ctx context.Context) error {
    // データベースの組み込みping機能を使用
    return c.db.PingContext(ctx)
}

// Redisのヘルスチェック
// Redisキャッシュの実装例
type RedisClient struct {
    client *redis.Client
}

func (c *RedisClient) Name() string {
    return "Redis"
}

func (c *RedisClient) Ping(ctx context.Context) error {
    // RedisのPINGコマンドを使用
    return c.client.Ping(ctx).Err()
}

// HTTPサービスのヘルスチェック
type ServiceClient struct {
    name   string
    client *http.Client
    url    string
}

func (c *ServiceClient) Name() string {
    return c.name
}

func (c *ServiceClient) Ping(ctx context.Context) error {
    // タイムアウト処理用のコンテキスト付きでリクエストを作成
    req, err := http.NewRequestWithContext(ctx,
        "GET", c.url+"/health", nil)
    if err != nil {
        return err
    }
    
    // ヘルスチェックリクエストを実行
    resp, err := c.client.Do(req)
    if err != nil {
        return err
    }
    defer resp.Body.Close()
    
    // レスポンスステータスをチェック
    if resp.StatusCode != http.StatusOK {
        return fmt.Errorf("サービスが異常: %d", resp.StatusCode)
    }
    
    return nil
}

// gRPCサービスのヘルスチェック
type GRPCClient struct {
    name string
    conn *grpc.ClientConn
}

func (c *GRPCClient) Name() string {
    return c.name
}

func (c *GRPCClient) Ping(ctx context.Context) error {
    // 標準gRPCヘルスチェックプロトコルを使用
    return c.conn.Invoke(ctx,
        "/grpc.health.v1.Health/Check",
        &healthpb.HealthCheckRequest{},
        &healthpb.HealthCheckResponse{})
}

// カスタムビジネスロジックチェック
type BusinessCheck struct {
    store *Store
}

func (c *BusinessCheck) Name() string {
    return "BusinessLogic"
}

func (c *BusinessCheck) Ping(ctx context.Context) error {
    // 重要なビジネス条件をチェック
    ok, err := c.store.CheckConsistency(ctx)
    if err != nil {
        return err
    }
    if !ok {
        return errors.New("データの不整合を検出")
    }
    return nil
}

// システムリソースチェック
type ResourceCheck struct {
    threshold float64
}

func (c *ResourceCheck) Name() string {
    return "SystemResources"
}

func (c *ResourceCheck) Ping(ctx context.Context) error {
    // メモリ使用量をチェック
    var m runtime.MemStats
    runtime.ReadMemStats(&m)
    
    memoryUsage := float64(m.Alloc) / float64(m.Sys)
    if memoryUsage > c.threshold {
        return fmt.Errorf("メモリ使用量が高すぎます: %.2f", memoryUsage)
    }
    
    return nil
}