Function TestPipelines

pkg/traceql/parse_test.go:445–488

(t *testing.T)

}

func TestPipelines(t *testing.T) {
	tests := []struct {
		in          string
		expected    Pipeline
		expectedStr string
	}{
		{
			in: "{ .a } | { .b }",
			expected: newPipeline(
				newSpansetFilter(NewAttribute("a")),
				newSpansetFilter(NewAttribute("b")),
			),
			expectedStr: "{ .a }|{ .b }",
		},
		{
			in: "{ .a } | count() > 1",
			expected: newPipeline(
				newSpansetFilter(NewAttribute("a")),
				newScalarFilter(OpGreater, newAggregate(aggregateCount, nil), NewStaticInt(1)),
			),
			expectedStr: "{ .a }|(count()) > 1",
		},
		{
			in: "{ .a } | by(.namespace) | coalesce() | avg(duration) = 1s ",
			expected: newPipeline(
				newSpansetFilter(NewAttribute("a")),
				newGroupOperation(NewAttribute("namespace")),
				newCoalesceOperation(),
				newScalarFilter(OpEqual, newAggregate(aggregateAvg, NewIntrinsic(IntrinsicDuration)), NewStaticDuration(time.Second)),
			),
			expectedStr: "{ .a }|by(.namespace)|coalesce()|(avg(duration)) = 1s",
		},
	}

	for _, tc := range tests {
		t.Run(tc.in, func(t *testing.T) {
			actual, err := Parse(tc.in)

			require.NoError(t, err)
			require.Equal(t, newRootExpr(tc.expected), actual)
			require.Equal(t, tc.expectedStr, actual.String())
		})
	}
}

func TestGroupCoalesceErrors(t *testing.T) {
	tests := []struct {