Skip to content

Commit 81e6cd8

Browse files
revert unneeded changes
1 parent 585c9ef commit 81e6cd8

File tree

4 files changed

+6
-8
lines changed

4 files changed

+6
-8
lines changed

internal/component/pyroscope/receive_http/receive_http.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ import (
1414
"github.com/go-kit/log"
1515
"github.com/gorilla/mux"
1616
pyroutil "github.com/grafana/alloy/internal/component/pyroscope/util"
17-
"github.com/grafana/alloy/internal/component/pyroscope/util/tracelog"
1817
"github.com/prometheus/client_golang/prometheus"
1918
"github.com/prometheus/prometheus/model/labels"
2019
"go.opentelemetry.io/otel/trace"
@@ -171,7 +170,7 @@ func (c *Component) Push(ctx context.Context, req *connect.Request[pushv1.PushRe
171170

172171
ctx, sp := c.tracer.Start(ctx, "/push.v1.PusherService/Push")
173172
defer sp.End()
174-
l := tracelog.TraceLog(c.logger, sp)
173+
l := pyroutil.TraceLog(c.logger, sp)
175174

176175
var wg sync.WaitGroup
177176
var errs error
@@ -225,7 +224,7 @@ func (c *Component) handleIngest(w http.ResponseWriter, r *http.Request) {
225224
ctx, sp := c.tracer.Start(ctx, "/ingest")
226225
defer sp.End()
227226

228-
l := tracelog.TraceLog(c.logger, sp)
227+
l := pyroutil.TraceLog(c.logger, sp)
229228

230229
// Parse labels early
231230
var lbls labels.Labels

internal/component/pyroscope/util/internal/cmd/playground/main.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ func main() {
9595
}
9696
}
9797

98-
func newJava(ps pids, w pyroscope.Appendable) interface{ Run(context.Context) error } {
98+
func newJava(ps pids, w pyroscope.Appendable) *java.Component {
9999
args := java.DefaultArguments()
100100
args.ForwardTo = []pyroscope.Appendable{w}
101101
for _, pid := range ps {

internal/component/pyroscope/util/tracelog/log.go renamed to internal/component/pyroscope/util/log.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package tracelog
1+
package util
22

33
import (
44
"github.com/go-kit/log"

internal/component/pyroscope/write/write.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ import (
2222
"github.com/grafana/alloy/internal/component/common/config"
2323
"github.com/grafana/alloy/internal/component/pyroscope"
2424
"github.com/grafana/alloy/internal/component/pyroscope/util"
25-
"github.com/grafana/alloy/internal/component/pyroscope/util/tracelog"
2625
"github.com/grafana/alloy/internal/featuregate"
2726
"github.com/grafana/alloy/internal/useragent"
2827
"github.com/grafana/dskit/backoff"
@@ -261,7 +260,7 @@ func (f *fanOutClient) Push(
261260
dl any
262261
ok bool
263262
reqSize, profileCount = requestSize(req)
264-
l = tracelog.TraceLog(f.logger, sp)
263+
l = util.TraceLog(f.logger, sp)
265264
st = time.Now()
266265
)
267266
if dl, ok = ctx.Deadline(); !ok {
@@ -467,7 +466,7 @@ func (f *fanOutClient) AppendIngest(ctx context.Context, profile *pyroscope.Inco
467466
dl any
468467
ok bool
469468
reqSize, profileCount = int64(len(profile.RawBody)), int64(1)
470-
l = tracelog.TraceLog(f.logger, sp)
469+
l = util.TraceLog(f.logger, sp)
471470
st = time.Now()
472471
)
473472
if dl, ok = ctx.Deadline(); !ok {

0 commit comments

Comments
 (0)