[v2][adjuster] Implement function to get standard adjusters to operate on otlp format

cmd/query/app/querysvc/adjuster/hash.go

@@ -23,8 +23,8 @@ var _ Adjuster = (*SpanHashDeduper)(nil)
 //
 // To ensure consistent hash codes, this adjuster should be executed after
 // SortAttributesAndEvents, which normalizes the order of collections within the span.
-func SpanHash() SpanHashDeduper {
-	return SpanHashDeduper{
+func SpanHash() *SpanHashDeduper {
+	return &SpanHashDeduper{
 		marshaler: &ptrace.ProtoMarshaler{},
 	}
 }
@@ -33,7 +33,7 @@ type SpanHashDeduper struct {
 	marshaler ptrace.Marshaler
 }
 
-func (s *SpanHashDeduper) Adjust(traces ptrace.Traces) {
+func (s SpanHashDeduper) Adjust(traces ptrace.Traces) {
 	spansByHash := make(map[uint64]ptrace.Span)
 	resourceSpans := traces.ResourceSpans()
 	for i := 0; i < resourceSpans.Len(); i++ {
@@ -70,7 +70,7 @@ func (s *SpanHashDeduper) Adjust(traces ptrace.Traces) {
 	}
 }
 
-func (s *SpanHashDeduper) computeHashCode(
+func (s SpanHashDeduper) computeHashCode(
 	hashTrace ptrace.Traces,
 ) (uint64, error) {
 	b, err := s.marshaler.MarshalTraces(hashTrace)

cmd/query/app/querysvc/adjuster/standard.go

@@ -0,0 +1,22 @@
+// Copyright (c) 2024 The Jaeger Authors.
+// SPDX-License-Identifier: Apache-2.0
+
+package adjuster
+
+import (
+	"time"
+)
+
+// StandardAdjusters returns a list of adjusters applied by the query service
+// before returning the data to the API clients.
+func StandardAdjusters(maxClockSkewAdjust time.Duration) []Adjuster {
+	return []Adjuster{
+		SpanIDUniquifier(),
+		SortAttributesAndEvents(),
+		SpanHash(),                    // requires SortAttributesAndEvents for deterministic results
+		ClockSkew(maxClockSkewAdjust), // adds warnings (which affect SpanHash) on duplicate span IDs
+		IPAttribute(),
+		ResourceAttributes(),
+		SpanLinks(),
+	}
+}

cmd/query/app/querysvc/adjuster/standard_test.go

@@ -0,0 +1,25 @@
+// Copyright (c) 2024 The Jaeger Authors.
+// SPDX-License-Identifier: Apache-2.0
+
+package adjuster
+
+import (
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestStandardAdjusters(t *testing.T) {
+	maxClockSkewAdjust := 10 * time.Second
+	adjusters := StandardAdjusters(maxClockSkewAdjust)
+
+	assert.Len(t, adjusters, 7, "Expected 7 adjusters")
+	assert.IsType(t, SpanIDUniquifier(), adjusters[0])
+	assert.IsType(t, SortAttributesAndEvents(), adjusters[1])
+	assert.IsType(t, SpanHash(), adjusters[2])
+	assert.IsType(t, ClockSkew(maxClockSkewAdjust), adjusters[3])
+	assert.IsType(t, IPAttribute(), adjusters[4])
+	assert.IsType(t, ResourceAttributes(), adjusters[5])
+	assert.IsType(t, SpanLinks(), adjusters[6])
+}