Function TestEngine_asTraceSearchMetadata

pkg/traceql/engine_test.go:207–357

(t *testing.T)

}

func TestEngine_asTraceSearchMetadata(t *testing.T) {
	now := time.Now()

	traceID, err := util.HexStringToTraceID("123456789abcdef")
	require.NoError(t, err)
	spanID1 := traceID[:8]
	spanID2 := traceID[8:]

	spanSet := &Spanset{
		TraceID:            traceID,
		RootServiceName:    "my-service",
		RootSpanName:       "HTTP GET",
		StartTimeUnixNanos: 1000,
		DurationNanos:      uint64(time.Second.Nanoseconds()),
		ServiceStats: map[string]ServiceStats{
			"service1": {
				SpanCount:  2,
				ErrorCount: 1,
			},
		},
		Spans: []Span{
			&mockSpan{
				id:                 spanID1,
				startTimeUnixNanos: uint64(now.UnixNano()),
				durationNanos:      uint64((10 * time.Second).Nanoseconds()),
				attributes: map[Attribute]Static{
					NewIntrinsic(IntrinsicName):     NewStaticString("HTTP GET"),
					NewIntrinsic(IntrinsicStatus):   NewStaticStatus(StatusOk),
					NewIntrinsic(IntrinsicKind):     NewStaticKind(KindClient),
					NewAttribute("cluster"):         NewStaticString("prod"),
					NewAttribute("count"):           NewStaticInt(5),
					NewAttribute("count_but_float"): NewStaticFloat(5.0),
					NewAttribute("is_ok"):           NewStaticBool(true),
					NewIntrinsic(IntrinsicDuration): NewStaticDuration(10 * time.Second),
				},
			},
			&mockSpan{
				id:                 spanID2,
				startTimeUnixNanos: uint64(now.Add(2 * time.Second).UnixNano()),
				durationNanos:      uint64((20 * time.Second).Nanoseconds()),
				attributes:         map[Attribute]Static{},
			},
		},
		Attributes: []*SpansetAttribute{
			{Name: attributeMatched, Val: NewStaticInt(2)},
			{Name: "avg(duration)", Val: NewStaticFloat(15.0)},
		},
	}

	traceSearchMetadata := asTraceSearchMetadata(spanSet)

	expectedSpanset := &tempopb.SpanSet{
		Matched: 2,
		Spans: []*tempopb.Span{
			{
				SpanID:            util.SpanIDToHexString(spanID1),
				Name:              "HTTP GET",
				StartTimeUnixNano: uint64(now.UnixNano()),