From c100a238d2e24074caf7a6458723892d569a594d Mon Sep 17 00:00:00 2001 From: Steven Fairchild Date: Fri, 14 Jun 2024 15:36:05 -0400 Subject: [PATCH] Add correlationid to dimensions --- pkg/cluster/install_metrics.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/pkg/cluster/install_metrics.go b/pkg/cluster/install_metrics.go index ea2e51816f9..10cbb603df7 100644 --- a/pkg/cluster/install_metrics.go +++ b/pkg/cluster/install_metrics.go @@ -9,6 +9,7 @@ import ( "strconv" "github.com/Azure/ARO-RP/pkg/api" + "github.com/Azure/ARO-RP/pkg/frontend/middleware" ) const ( @@ -23,6 +24,8 @@ const ( func (m *manager) gatherEmitInstallMetrics(ctx context.Context) error { dimensions := map[string]string{} + m.gatherCorrelationID(ctx, dimensions) + m.gatherMiscMetrics(dimensions) err := m.gatherAuthMetrics(dimensions) @@ -45,6 +48,13 @@ func (m *manager) gatherEmitInstallMetrics(ctx context.Context) error { return nil } +func (m *manager) gatherCorrelationID(ctx context.Context, dimensions map[string]string) { + correlationData := ctx.Value(middleware.ContextKeyCorrelationData).(*api.CorrelationData) + + dimensions["correlationid"] = correlationData.CorrelationID + dimensions["clientrequestid"] = correlationData.ClientRequestID +} + func (m *manager) gatherMiscMetrics(dimensions map[string]string) { dimensions["resourceid"] = m.doc.ResourceID dimensions["subscriptionid"] = m.env.SubscriptionID()