diff --git a/cmd/thanos/bucket.go b/cmd/thanos/bucket.go index 1b19fece34..124586c5cb 100644 --- a/cmd/thanos/bucket.go +++ b/cmd/thanos/bucket.go @@ -332,7 +332,7 @@ func registerBucketWeb(m map[string]setupFunc, root *kingpin.CmdClause, name str httpProbe := prober.NewHTTP() statusProber := prober.Combine( httpProbe, - prober.NewInstrumentation(comp, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(comp, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) srv := httpserver.New(logger, reg, comp, httpProbe, diff --git a/cmd/thanos/compact.go b/cmd/thanos/compact.go index 704b387a77..3485da1758 100644 --- a/cmd/thanos/compact.go +++ b/cmd/thanos/compact.go @@ -251,7 +251,7 @@ func runCompact( httpProbe := prober.NewHTTP() statusProber := prober.Combine( httpProbe, - prober.NewInstrumentation(component, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(component, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) srv := httpserver.New(logger, reg, component, httpProbe, diff --git a/cmd/thanos/downsample.go b/cmd/thanos/downsample.go index beb45b95a9..f2dd7c82dd 100644 --- a/cmd/thanos/downsample.go +++ b/cmd/thanos/downsample.go @@ -87,7 +87,7 @@ func RunDownsample( httpProbe := prober.NewHTTP() statusProber := prober.Combine( httpProbe, - prober.NewInstrumentation(comp, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(comp, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) metrics := newDownsampleMetrics(reg) diff --git a/cmd/thanos/query.go b/cmd/thanos/query.go index 0d687b02e1..ed266904e7 100644 --- a/cmd/thanos/query.go +++ b/cmd/thanos/query.go @@ -318,7 +318,7 @@ func runQuery( statusProber := prober.Combine( httpProbe, grpcProbe, - prober.NewInstrumentation(comp, logger, reg), + prober.NewInstrumentation(comp, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) // Start query API + UI HTTP server. diff --git a/cmd/thanos/receive.go b/cmd/thanos/receive.go index 59db2ed840..2296e4649e 100644 --- a/cmd/thanos/receive.go +++ b/cmd/thanos/receive.go @@ -24,6 +24,7 @@ import ( "github.com/thanos-io/thanos/pkg/component" "github.com/thanos-io/thanos/pkg/extflag" "github.com/thanos-io/thanos/pkg/extgrpc" + "github.com/thanos-io/thanos/pkg/extprom" "github.com/thanos-io/thanos/pkg/objstore/client" "github.com/thanos-io/thanos/pkg/prober" "github.com/thanos-io/thanos/pkg/receive" @@ -212,7 +213,7 @@ func runReceive( statusProber := prober.Combine( httpProbe, grpcProbe, - prober.NewInstrumentation(comp, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(comp, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) confContentYaml, err := objStoreConfig.Content() diff --git a/cmd/thanos/rule.go b/cmd/thanos/rule.go index 87afc357d3..290ec41c00 100644 --- a/cmd/thanos/rule.go +++ b/cmd/thanos/rule.go @@ -523,7 +523,7 @@ func runRule( statusProber := prober.Combine( httpProbe, grpcProbe, - prober.NewInstrumentation(comp, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(comp, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) // Start gRPC server. diff --git a/cmd/thanos/sidecar.go b/cmd/thanos/sidecar.go index 3024b1a716..caed499963 100644 --- a/cmd/thanos/sidecar.go +++ b/cmd/thanos/sidecar.go @@ -24,6 +24,7 @@ import ( "github.com/thanos-io/thanos/pkg/component" "github.com/thanos-io/thanos/pkg/extflag" "github.com/thanos-io/thanos/pkg/exthttp" + "github.com/thanos-io/thanos/pkg/extprom" thanosmodel "github.com/thanos-io/thanos/pkg/model" "github.com/thanos-io/thanos/pkg/objstore/client" "github.com/thanos-io/thanos/pkg/prober" @@ -163,7 +164,7 @@ func runSidecar( statusProber := prober.Combine( httpProbe, grpcProbe, - prober.NewInstrumentation(comp, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(comp, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) srv := httpserver.New(logger, reg, comp, httpProbe, diff --git a/cmd/thanos/store.go b/cmd/thanos/store.go index 8031cd84e8..79c7315c3d 100644 --- a/cmd/thanos/store.go +++ b/cmd/thanos/store.go @@ -168,7 +168,7 @@ func runStore( statusProber := prober.Combine( httpProbe, grpcProbe, - prober.NewInstrumentation(component, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(component, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) srv := httpserver.New(logger, reg, component, httpProbe, diff --git a/pkg/replicate/replicator.go b/pkg/replicate/replicator.go index d419681f85..198faf8162 100644 --- a/pkg/replicate/replicator.go +++ b/pkg/replicate/replicator.go @@ -24,6 +24,7 @@ import ( "github.com/thanos-io/thanos/pkg/compact" "github.com/thanos-io/thanos/pkg/component" "github.com/thanos-io/thanos/pkg/extflag" + "github.com/thanos-io/thanos/pkg/extprom" "github.com/thanos-io/thanos/pkg/objstore/client" "github.com/thanos-io/thanos/pkg/prober" "github.com/thanos-io/thanos/pkg/runutil" @@ -81,7 +82,7 @@ func RunReplicate( httpProbe := prober.NewHTTP() statusProber := prober.Combine( httpProbe, - prober.NewInstrumentation(component.Replicate, logger, prometheus.WrapRegistererWithPrefix("thanos_", reg)), + prober.NewInstrumentation(component.Replicate, logger, extprom.WrapRegistererWithPrefix("thanos_", reg)), ) s := http.New(logger, reg, component.Replicate, httpProbe,