Skip to content

Commit 913ab9c

Browse files
committed
Rebasing and fixing merge conflicts
1 parent 06bbca6 commit 913ab9c

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

processor/tailsamplingprocessor/internal/metadata/generated_telemetry.go

Lines changed: 1 addition & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

processor/tailsamplingprocessor/internal/sampling/composite_test.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ func TestCompositeEvaluatorNotSampled(t *testing.T) {
6262
max100 := int64(100)
6363
n1 := NewNumericAttributeFilter(componenttest.NewNopTelemetrySettings(), "tag", &min0, &max100, false)
6464
n2 := NewNumericAttributeFilter(componenttest.NewNopTelemetrySettings(), "tag", &min0, &max100, false)
65-
c := NewComposite(zap.NewNop(), 1000, []SubPolicyEvalParams{{n1, 100, "eval-1"}, {n2, 100, "eval-2"}}, FakeTimeProvider{}, false)
65+
c := NewComposite(zap.NewNop(), 1000, []SubPolicyEvalParams{{n1, 100, "eval-1"}, {n2, 100, "eval-2"}}, FakeTimeProvider{}, false)
6666

6767
trace := createTrace()
6868

@@ -95,7 +95,9 @@ func TestCompositeEvaluatorSampled(t *testing.T) {
9595

9696
func TestCompositeEvaluatorSampled_RecordSubPolicy(t *testing.T) {
9797
// Create 2 subpolicies. First results in 100% NotSampled, the second in 100% Sampled.
98-
n1 := NewNumericAttributeFilter(componenttest.NewNopTelemetrySettings(), "tag", 0, 100, false)
98+
min0 := int64(0)
99+
max100 := int64(100)
100+
n1 := NewNumericAttributeFilter(componenttest.NewNopTelemetrySettings(), "tag", &min0, &max100, false)
99101
n2 := NewAlwaysSample(componenttest.NewNopTelemetrySettings())
100102
c := NewComposite(zap.NewNop(), 1000, []SubPolicyEvalParams{{n1, 100, "eval-1"}, {n2, 100, "eval-2"}}, FakeTimeProvider{}, true)
101103

processor/tailsamplingprocessor/processor.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -416,10 +416,9 @@ func (tsp *tailSamplingSpanProcessor) makeDecision(id pcommon.TraceID, trace *sa
416416
tsp.telemetry.ProcessorTailSamplingCountSpansSampled.Add(ctx, trace.SpanCount.Load(), p.attribute, decisionToAttribute[decision])
417417
}
418418

419-
// We associate the first policy with the sampling decision to understand what policy sampled a span
420-
if samplingDecisions[decision] == nil {
421-
samplingDecisions[decision] = p
422-
}
419+
// We associate the first policy with the sampling decision to understand what policy sampled a span
420+
if samplingDecisions[decision] == nil {
421+
samplingDecisions[decision] = p
423422
}
424423
}
425424

0 commit comments

Comments
 (0)