Function TestProcessAttributes

modules/distributor/distributor_test.go:957–1081

(t *testing.T)

}

func TestProcessAttributes(t *testing.T) {
	spanCount := 10
	batchCount := 3
	trace := test.MakeTraceWithSpanCount(batchCount, spanCount, []byte{0x0A, 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F})

	maxAttrByte := 1000
	longString := strings.Repeat("t", 1100)

	// add long attributes to the resource level
	trace.ResourceSpans[0].Resource.Attributes = append(trace.ResourceSpans[0].Resource.Attributes,
		test.MakeAttribute("long value", longString),
	)
	trace.ResourceSpans[0].Resource.Attributes = append(trace.ResourceSpans[0].Resource.Attributes,
		test.MakeAttribute(longString, "long key"),
	)

	// add long attributes to the span level
	trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Attributes = append(trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Attributes,
		test.MakeAttribute("long value", longString),
	)
	trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Attributes = append(trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Attributes,
		test.MakeAttribute(longString, "long key"),
	)

	// add long attributes to the event level
	trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Events = append(trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Events,
		&v1.Span_Event{
			TimeUnixNano: 0,
			Attributes: []*v1_common.KeyValue{
				test.MakeAttribute("long value", longString),
				test.MakeAttribute(longString, "long key"),
			},
		},
	)

	// add long attributes to the link level
	trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Links = append(trace.ResourceSpans[0].ScopeSpans[0].Spans[0].Links,
		&v1.Span_Link{
			TraceId: []byte{0x0A, 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F},
			SpanId:  []byte{0x0A, 0x01, 0x02, 0x03, 0x04, 0x05, 0x06, 0x07, 0x08, 0x09, 0x0A, 0x0B, 0x0C, 0x0D, 0x0E, 0x0F},
			Attributes: []*v1_common.KeyValue{
				test.MakeAttribute("long value", longString),
				test.MakeAttribute(longString, "long key"),
			},
		},
	)

	// add long attributes to scope level
	trace.ResourceSpans[0].ScopeSpans[0].Scope = &v1_common.InstrumentationScope{
		Name:    "scope scope",
		Version: "1.0",
		Attributes: []*v1_common.KeyValue{
			test.MakeAttribute("long value", longString),
			test.MakeAttribute(longString, "long key"),
		},
	}

	_, rebatchedTrace, truncatedCount, _, _ := requestsByTraceID(trace.ResourceSpans, "test", spanCount*batchCount, maxAttrByte)