Goaにおける可観測性

import (
    "go.opentelemetry.io/otel"                // 標準OpenTelemetry
    "go.opentelemetry.io/otel/attribute"      // 標準OpenTelemetry
    "goa.design/clue/log"                     // Clueのロギングパッケージ
)

func (s *Service) CreateOrder(ctx context.Context, order *Order) error {
    // 標準OpenTelemetry APIの使用
    ctx, span := otel.Tracer("service").Start(ctx, "create_order")
    defer span.End()

    // 標準OpenTelemetryの属性
    span.SetAttributes(
        attribute.String("order.id", order.ID),
        attribute.Float64("order.amount", order.Amount))

    // 標準OpenTelemetryのメトリクス
    s.orderCounter.Add(ctx, 1,
        attribute.String("type", order.Type))

    // Clueの構造化ロギング（オプション）
    log.Info(ctx, "注文を処理中",
        log.KV{"order_id", order.ID})

    if err := s.processOrder(ctx, order); err != nil {
        // 標準OpenTelemetryのエラー記録
        span.RecordError(err)
        return err
    }

    return nil
}

func main() {
    // 1. 適切なフォーマットでロガーを作成
    format := log.FormatJSON
    if log.IsTerminal() {
        format = log.FormatTerminal
    }
    ctx := log.Context(context.Background(),
        log.WithFormat(format),
        log.WithFunc(log.Span))

    // 2. OTLPエクスポーターでOpenTelemetryを設定
    spanExporter, err := otlptracegrpc.New(ctx,
        otlptracegrpc.WithEndpoint(*coladdr),
        otlptracegrpc.WithTLSCredentials(insecure.NewCredentials()))
    if err != nil {
        log.Fatalf(ctx, err, "トレーシングの初期化に失敗しました")
    }
    metricExporter, err := otlpmetricgrpc.New(ctx,
        otlpmetricgrpc.WithEndpoint(*coladdr),
        otlpmetricgrpc.WithTLSCredentials(insecure.NewCredentials()))
    if err != nil {
        log.Fatalf(ctx, err, "メトリクスの初期化に失敗しました")
    }

    // 3. OpenTelemetryでClueを初期化
    cfg, err := clue.NewConfig(ctx,
        genservice.ServiceName,
        genservice.APIVersion,
        metricExporter,
        spanExporter)
    clue.ConfigureOpenTelemetry(ctx, cfg)

    // 4. ミドルウェア付きでサービスを作成
    svc := front.New(fc, lc)
    endpoints := genservice.NewEndpoints(svc)
    endpoints.Use(debug.LogPayloads())  // デバッグロギング
    endpoints.Use(log.Endpoint)         // リクエストロギング
    endpoints.Use(middleware.ErrorReporter())

    // 5. 可観測性を備えたHTTPハンドラーのセットアップ
    mux := goahttp.NewMuxer()
    debug.MountDebugLogEnabler(debug.Adapt(mux))  // 動的ログレベル制御
    debug.MountPprofHandlers(debug.Adapt(mux))    // Goプロファイリングエンドポイント
    
    // 正しい順序でミドルウェアを追加：
    handler := otelhttp.NewHandler(mux, serviceName)  // 3. OpenTelemetry
    handler = debug.HTTP()(handler)                   // 2. デバッグエンドポイント
    handler = log.HTTP(ctx)(handler)                  // 1. リクエストロギング

    // 6. 別ポートでヘルスチェックをマウント
    check := health.Handler(health.NewChecker(
        health.NewPinger("locator", *locatorHealthAddr),
        health.NewPinger("forecaster", *forecasterHealthAddr)))
    http.Handle("/healthz", log.HTTP(ctx)(check))

    // 7. グレースフルシャットダウン付きでサーバーを起動
    var wg sync.WaitGroup
    wg.Add(1)
    go func() {
        defer wg.Done()
        log.Printf(ctx, "HTTPサーバーが%sでリッスン中", *httpAddr)
        if err := server.ListenAndServe(); err != http.ErrServerClosed {
            log.Errorf(ctx, err, "サーバーエラー")
        }
    }()

    // シャットダウンの処理
    <-ctx.Done()
    if err := server.Shutdown(context.Background()); err != nil {
        log.Errorf(ctx, err, "シャットダウンエラー")
    }
    wg.Wait()
}