Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
ndk committed Feb 7, 2025
1 parent 7e2974d commit 8e1feb4
Show file tree
Hide file tree
Showing 6 changed files with 0 additions and 320 deletions.
3 changes: 0 additions & 3 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,3 @@ integration/e2e/deployments/e2e_integration_test[0-9]*
/tmp
gh-token.txt
.cache
.devcontainer
testdata
k6
114 changes: 0 additions & 114 deletions tempodb/encoding/vparquet4/block_traceql_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ package vparquet4
import (
"bytes"
"context"
"embed"
"fmt"
"math"
"math/rand"
Expand Down Expand Up @@ -55,119 +54,6 @@ func TestOne(t *testing.T) {
fmt.Println(spanSet)
}

//go:embed testqt/*.txt
var testqt embed.FS

func TestMixedTypesQuery(t *testing.T) {
t.Run("integer attribute with float", func(t *testing.T) {
wantTr := fullyPopulatedTestTrace(nil)
b := makeBackendBlockWithTraces(t, []*Trace{wantTr})
ctx := context.Background()
q := `{.crossint > 122.9}`
req := traceql.MustExtractFetchSpansRequestWithMetadata(q)

req.StartTimeUnixNanos = uint64(1000 * time.Second)
req.EndTimeUnixNanos = uint64(1001 * time.Second)

resp, err := b.Fetch(ctx, req, common.DefaultSearchOptions())
require.NoError(t, err, "search request:", req)

spanSet, err := resp.Results.Next(ctx)
require.NoError(t, err, "search request:", req)

fmt.Println(q)
fmt.Println("-----------")
fmt.Println(resp.Results.(*spansetIterator).iter)
fmt.Println("-----------")
fmt.Println(spanSet)

queryTree, err := testqt.ReadFile("testqt/intattr.txt")
require.NoError(t, err)
require.Equal(t, string(queryTree), resp.Results.(*spansetIterator).iter.String())
})

t.Run("float attribute with integer", func(t *testing.T) {
wantTr := fullyPopulatedTestTrace(nil)
b := makeBackendBlockWithTraces(t, []*Trace{wantTr})
ctx := context.Background()
q := `{.crossfloat = 456}`
req := traceql.MustExtractFetchSpansRequestWithMetadata(q)

req.StartTimeUnixNanos = uint64(1000 * time.Second)
req.EndTimeUnixNanos = uint64(1001 * time.Second)

resp, err := b.Fetch(ctx, req, common.DefaultSearchOptions())
require.NoError(t, err, "search request:", req)

spanSet, err := resp.Results.Next(ctx)
require.NoError(t, err, "search request:", req)

fmt.Println(q)
fmt.Println("-----------")
fmt.Println(resp.Results.(*spansetIterator).iter)
fmt.Println("-----------")
fmt.Println(spanSet)

queryTree, err := testqt.ReadFile("testqt/floatattr.txt")
require.NoError(t, err)
require.Equal(t, string(queryTree), resp.Results.(*spansetIterator).iter.String())
})

t.Run("span.http.status_code", func(t *testing.T) {
wantTr := fullyPopulatedTestTrace(nil)
b := makeBackendBlockWithTraces(t, []*Trace{wantTr})
ctx := context.Background()
q := `{span.http.status_code = 123 || span.http.status_code <= 456.7}`
req := traceql.MustExtractFetchSpansRequestWithMetadata(q)

req.StartTimeUnixNanos = uint64(1000 * time.Second)
req.EndTimeUnixNanos = uint64(1001 * time.Second)

resp, err := b.Fetch(ctx, req, common.DefaultSearchOptions())
require.NoError(t, err, "search request:", req)

spanSet, err := resp.Results.Next(ctx)
require.NoError(t, err, "search request:", req)

fmt.Println(q)
fmt.Println("-----------")
fmt.Println(resp.Results.(*spansetIterator).iter)
fmt.Println("-----------")
fmt.Println(spanSet)

queryTree, err := testqt.ReadFile("testqt/statuscode.txt")
require.NoError(t, err)
require.Equal(t, string(queryTree), resp.Results.(*spansetIterator).iter.String())
})

t.Run("span.http.status_code (2)", func(t *testing.T) {
wantTr := fullyPopulatedTestTrace(nil)
b := makeBackendBlockWithTraces(t, []*Trace{wantTr})
ctx := context.Background()
q := `{ span.http.status_code = 200 && span.http.status_code = 200. }`
req := traceql.MustExtractFetchSpansRequestWithMetadata(q)

req.StartTimeUnixNanos = uint64(1000 * time.Second)
req.EndTimeUnixNanos = uint64(1001 * time.Second)

resp, err := b.Fetch(ctx, req, common.DefaultSearchOptions())
require.NoError(t, err, "search request:", req)

spanSet, err := resp.Results.Next(ctx)
require.NoError(t, err, "search request:", req)

fmt.Println(q)
fmt.Println("-----------")
fmt.Println(resp.Results.(*spansetIterator).iter)
fmt.Println("-----------")
fmt.Println(spanSet)

queryTree, err := testqt.ReadFile("testqt/statuscode2.txt")
require.NoError(t, err)
require.Equal(t, string(queryTree), resp.Results.(*spansetIterator).iter.String())
})
}

func TestCreateIntPredicateFromFloat(t *testing.T) {
f := func(query string, predicate string) {
req := traceql.MustExtractFetchSpansRequestWithMetadata(query)
Expand Down
54 changes: 0 additions & 54 deletions tempodb/encoding/vparquet4/testqt/floatattr.txt

This file was deleted.

54 changes: 0 additions & 54 deletions tempodb/encoding/vparquet4/testqt/intattr.txt

This file was deleted.

48 changes: 0 additions & 48 deletions tempodb/encoding/vparquet4/testqt/statuscode.txt

This file was deleted.

47 changes: 0 additions & 47 deletions tempodb/encoding/vparquet4/testqt/statuscode2.txt

This file was deleted.

0 comments on commit 8e1feb4

Please sign in to comment.