public/grafana
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rename utils for clarity

Browse Source
This commit is contained in:
Jocelyn Collado-Kuri
2026-01-12 10:35:01 -08:00
parent 452b0acf09
commit 12fe570ce3
5 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/tsdb/tempo/metrics_stream.go
+2 -2
View File
@@ -8,7 +8,7 @@ import (
"io"
"github.com/grafana/grafana/pkg/tsdb/tempo/traceql"
"github.com/grafana/grafana/pkg/tsdb/tempo/util"
stream_utils "github.com/grafana/grafana/pkg/tsdb/tempo/utils"
"github.com/grafana/grafana-plugin-sdk-go/backend"
"github.com/grafana/grafana-plugin-sdk-go/backend/tracing"
@@ -64,7 +64,7 @@ func (s *Service) runMetricsStream(ctx context.Context, req *backend.RunStreamRe
qrr.Start = uint64(backendQuery.TimeRange.From.UnixNano())
qrr.End = uint64(backendQuery.TimeRange.To.UnixNano())
ctx = util.AppendHeadersToOutgoingContext(ctx, req)
ctx = stream_utils.AppendHeadersToOutgoingContext(ctx, req)
if isInstantQuery(tempoQuery.MetricsQueryType) {
instantQuery := &tempopb.QueryInstantRequest{
pkg/tsdb/tempo/search_stream.go
+2 -2
View File
@@ -11,7 +11,7 @@ import (
"github.com/grafana/grafana-plugin-sdk-go/backend/tracing"
"github.com/grafana/grafana-plugin-sdk-go/data"
"github.com/grafana/grafana/pkg/tsdb/tempo/kinds/dataquery"
"github.com/grafana/grafana/pkg/tsdb/tempo/util"
stream_utils "github.com/grafana/grafana/pkg/tsdb/tempo/utils"
"github.com/grafana/tempo/pkg/tempopb"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/codes"
@@ -60,7 +60,7 @@ func (s *Service) runSearchStream(ctx context.Context, req *backend.RunStreamReq
sr.Start = uint32(backendQuery.TimeRange.From.Unix())
sr.End = uint32(backendQuery.TimeRange.To.Unix())
ctx = util.AppendHeadersToOutgoingContext(ctx, req)
ctx = stream_utils.AppendHeadersToOutgoingContext(ctx, req)
stream, err := datasource.StreamingClient.Search(ctx, sr)
if err != nil {
pkg/tsdb/tempo/stream_handler.go
+2 -2
View File
@@ -6,7 +6,7 @@ import (
"strings"
"github.com/grafana/grafana-plugin-sdk-go/backend"
"github.com/grafana/grafana/pkg/tsdb/tempo/util"
stream_utils "github.com/grafana/grafana/pkg/tsdb/tempo/utils"
)
func (s *Service) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error) {
@@ -43,7 +43,7 @@ func (s *Service) RunStream(ctx context.Context, request *backend.RunStreamReque
tempoDatasource, dsInfoErr := s.getDSInfo(ctx, request.PluginContext)
// get incoming and team http headers and append to stream request.
headers, err := util.SetHeadersFromIncomingContext(ctx)
headers, err := stream_utils.SetHeadersFromIncomingContext(ctx)
if err != nil {
return err
}
pkg/tsdb/tempo/util/stream_util.go → pkg/tsdb/tempo/utils/stream_utils.go
+1 -1
View File
@@ -1,4 +1,4 @@
package util
package stream_utils
import (
"context"
pkg/tsdb/tempo/util/stream_util_test.go → pkg/tsdb/tempo/utils/stream_utils_test.go
+1 -1
View File
@@ -1,4 +1,4 @@
package util
package stream_utils
import (
"context"