トレーシング

// HTTPサーバーの場合、ハンドラーをOpenTelemetryミドルウェアでラップします。
// これにより、すべての受信リクエストのトレースが自動的に作成されます。
handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
    // ハンドラーのコード
})

// トレーシングミドルウェアを追加
handler = otelhttp.NewHandler(handler, "my-service")

// ミドルウェアは以下を行います：
// - 各リクエストのスパンを作成
// - HTTPメソッド、ステータスコード、URLを記録
// - リクエスト時間を追跡
// - コンテキストを下流のサービスに伝播

// トレーシングを有効にしたgRPCサーバーを作成
server := grpc.NewServer(
    // すべてのRPCをトレースするためにOpenTelemetryハンドラーを追加
    grpc.StatsHandler(otelgrpc.NewServerHandler()))

// これにより自動的に：
// - すべてのgRPCメソッドをトレース
// - メソッド名とステータスコードを記録
// - レイテンシーを追跡
// - コンテキストの伝播を処理

func processOrder(ctx context.Context, order *Order) error {
    // この操作の新しいスパンを開始。
    // スパン名"process_order"がトレースに表示されます。
    ctx, span := otel.Tracer("myservice").Start(ctx, "process_order")
    
    // 関数が戻る時に必ずスパンを終了
    defer span.End()

    // ビジネスコンテキストをスパン属性として追加
    span.SetAttributes(
        // これらはトレースのフィルタリングと分析に役立ちます
        attribute.String("order.id", order.ID),
        attribute.Float64("order.amount", order.Amount),
        attribute.String("customer.id", order.CustomerID))

    // タイムスタンプ付きで重要なイベントを記録
    span.AddEvent("validating_order")
    if err := validateOrder(ctx, order); err != nil {
        // コンテキスト付きでエラーを記録
        span.RecordError(err)
        span.SetStatus(codes.Error, "注文の検証に失敗しました")
        return err
    }
    span.AddEvent("order_validated")

    // サブ操作用のネストされたスパンを作成
    ctx, paymentSpan := otel.Tracer("myservice").Start(ctx, "process_payment")
    defer paymentSpan.End()

    if err := processPayment(ctx, order); err != nil {
        paymentSpan.RecordError(err)
        paymentSpan.SetStatus(codes.Error, "支払いに失敗しました")
        return err
    }

    return nil
}

// トレーシングを有効にしたHTTPクライアントを作成
client := &http.Client{
    // デフォルトのトランスポートをOpenTelemetryでラップ
    Transport: otelhttp.NewTransport(
        http.DefaultTransport,
        // 詳細なHTTPトレーシングを有効化（オプション）
        otelhttp.WithClientTrace(func(ctx context.Context) *httptrace.ClientTrace {
            return otelhttptrace.NewClientTrace(ctx)
        }),
    ),
}

// これですべてのリクエストが自動的にトレースされます
resp, err := client.Get("https://api.example.com/data")

// トレーシング付きのgRPCクライアント接続を作成
conn, err := grpc.DialContext(ctx,
    "service:8080",
    // OpenTelemetryハンドラーを追加
    grpc.WithStatsHandler(otelgrpc.NewClientHandler()),
    // その他のオプション...
    grpc.WithTransportCredentials(insecure.NewCredentials()))

// この接続を使用するすべての呼び出しがトレースされます
client := pb.NewServiceClient(conn)

func (r *Repository) GetUser(ctx context.Context, id string) (*User, error) {
    // データベース操作用のスパンを作成
    ctx, span := otel.Tracer("repository").Start(ctx, "get_user")
    defer span.End()

    // クエリのコンテキストを追加
    span.SetAttributes(
        attribute.String("db.type", "postgres"),
        attribute.String("db.user_id", id))

    // クエリを実行
    var user User
    if err := r.db.GetContext(ctx, &user, "SELECT * FROM users WHERE id = $1", id); err != nil {
        // データベースエラーを記録
        span.RecordError(err)
        span.SetStatus(codes.Error, "データベースクエリが失敗しました")
        return nil, err
    }

    return &user, nil
}

// リクエストを受信する際、トレースコンテキストを抽出
func handleIncoming(w http.ResponseWriter, r *http.Request) {
    // リクエストヘッダーからトレースコンテキストを抽出
    ctx := otel.GetTextMapPropagator().Extract(r.Context(),
        propagation.HeaderCarrier(r.Header))
    
    // このコンテキストをすべての操作で使用
    processRequest(ctx)
}

// リクエストを送信する際、トレースコンテキストを注入
func makeOutgoing(ctx context.Context) error {
    req, _ := http.NewRequestWithContext(ctx, "GET", "https://api.example.com", nil)
    
    // リクエストヘッダーにトレースコンテキストを注入
    otel.GetTextMapPropagator().Inject(ctx,
        propagation.HeaderCarrier(req.Header))
    
    resp, err := http.DefaultClient.Do(req)
    return err
}