mirrors/prometheus
1
0
Fork 0
mirror of https://github.com/prometheus/prometheus.git synced 2025-08-07 14:47:11 +02:00
Code Issues Projects Releases Wiki Activity

changes

Browse Source 
Signed-off-by: Vanshikav123 <vanshikav928@gmail.com>
This commit is contained in:
Vanshikav123 2025-05-08 17:00:38 +05:30
parent 4a0929019c
commit 6e98a77b2d
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
scrape/scrape.go
View File

@ -38,6 +38,7 @@ import (
"github.com/prometheus/common/version" "github.com/prometheus/common/version"
"go.opentelemetry.io/otel" "go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/propagation" "go.opentelemetry.io/otel/propagation"
"go.opentelemetry.io/otel/trace"
"github.com/prometheus/prometheus/config" "github.com/prometheus/prometheus/config"
"github.com/prometheus/prometheus/discovery/targetgroup" "github.com/prometheus/prometheus/discovery/targetgroup"
@ -821,8 +822,7 @@ func acceptEncodingHeader(enableCompression bool) string {
var UserAgent = version.PrometheusUserAgent() var UserAgent = version.PrometheusUserAgent()
func (s *targetScraper) scrape(ctx context.Context) (*http.Response, error) { func (s *targetScraper) scrape(ctx context.Context) (*http.Response, error) {
tracer := otel.GetTracerProvider().Tracer("prometheus/scraper") ctx, span := otel.Tracer("").Start(ctx, "Scrape", trace.WithSpanKind(trace.SpanKindClient))
ctx, span := tracer.Start(ctx, "scrape_"+s.URL().String())
defer span.End() defer span.End()
if s.req == nil { if s.req == nil {
@ -840,9 +840,7 @@ func (s *targetScraper) scrape(ctx context.Context) (*http.Response, error) {
req := s.req.WithContext(ctx) req := s.req.WithContext(ctx)
propagator := otel.GetTextMapPropagator() otel.GetTextMapPropagator().Inject(ctx, propagation.HeaderCarrier(req.Header))
propagator.Inject(ctx, propagation.HeaderCarrier(req.Header))
return s.client.Do(req) return s.client.Do(req)
} }