Skip to content

Commit afb98b2

Browse files
committed
Update ratio name
1 parent e0a1e98 commit afb98b2

File tree

4 files changed

+10
-13
lines changed

4 files changed

+10
-13
lines changed

internal/mode/static/policies/observability/generator.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package observability
22

33
import (
44
"fmt"
5-
"strings"
65
"text/template"
76

87
ngfAPI "github.com/nginxinc/nginx-gateway-fabric/apis/v1alpha1"
@@ -70,8 +69,5 @@ func Generate(policy policies.Policy, globalSettings *policies.GlobalPolicySetti
7069
// CreateRatioVarName builds a variable name for an ObservabilityPolicy to be used with
7170
// ratio-based trace sampling.
7271
func CreateRatioVarName(policy *ngfAPI.ObservabilityPolicy) string {
73-
namespace := strings.ReplaceAll(policy.GetNamespace(), "-", "_")
74-
name := strings.ReplaceAll(policy.GetName(), "-", "_")
75-
76-
return fmt.Sprintf("$ratio_ns_%s_name_%s", namespace, name)
72+
return fmt.Sprintf("$otel_ratio_%d", *policy.Spec.Tracing.Ratio)
7773
}

internal/mode/static/policies/observability/generator_test.go

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ func TestGenerate(t *testing.T) {
5353
},
5454
},
5555
expStrings: []string{
56-
"otel_trace $ratio_ns_test_namespace_name_test_policy;",
56+
"otel_trace $otel_ratio_25;",
5757
},
5858
},
5959
{
@@ -202,12 +202,13 @@ func TestGeneratePanics(t *testing.T) {
202202

203203
func TestCreateRatioVarName(t *testing.T) {
204204
pol := &ngfAPI.ObservabilityPolicy{
205-
ObjectMeta: metav1.ObjectMeta{
206-
Name: "test-policy",
207-
Namespace: "test-namespace",
205+
Spec: ngfAPI.ObservabilityPolicySpec{
206+
Tracing: &ngfAPI.Tracing{
207+
Ratio: helpers.GetPointer[int32](25),
208+
},
208209
},
209210
}
210211

211212
g := NewWithT(t)
212-
g.Expect(observability.CreateRatioVarName(pol)).To(Equal("$ratio_ns_test_namespace_name_test_policy"))
213+
g.Expect(observability.CreateRatioVarName(pol)).To(Equal("$otel_ratio_25"))
213214
}

internal/mode/static/state/dataplane/configuration.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -641,8 +641,8 @@ func buildTelemetry(g *graph.Graph) Telemetry {
641641
for _, pol := range g.NGFPolicies {
642642
if obsPol, ok := pol.Source.(*ngfAPI.ObservabilityPolicy); ok {
643643
if obsPol.Spec.Tracing != nil && obsPol.Spec.Tracing.Ratio != nil && *obsPol.Spec.Tracing.Ratio > 0 {
644-
nsName := observability.CreateRatioVarName(obsPol)
645-
ratioMap[nsName] = *obsPol.Spec.Tracing.Ratio
644+
ratioName := observability.CreateRatioVarName(obsPol)
645+
ratioMap[ratioName] = *obsPol.Spec.Tracing.Ratio
646646
}
647647
}
648648
}

internal/mode/static/state/dataplane/configuration_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3059,7 +3059,7 @@ func TestBuildTelemetry(t *testing.T) {
30593059
},
30603060
expTelemetry: createModifiedTelemetry(func(t Telemetry) Telemetry {
30613061
t.Ratios = []Ratio{
3062-
{Name: "$ratio_ns_custom_ns_name_obsPolicy", Value: 25},
3062+
{Name: "$otel_ratio_25", Value: 25},
30633063
}
30643064
return t
30653065
}),

0 commit comments

Comments
 (0)