github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 22:46:12 +00:00
Code Issues Projects Releases Wiki Activity

Use HandlerFor

Browse Source
This commit is contained in:
CatherineF-dev 2021-11-12 23:09:51 +00:00
parent 49d341aa2b
commit d9737eabf4
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/kubelet/kuberuntime/instrumented_services_test.go
View File

@ -22,7 +22,6 @@ import (
"testing" "testing"
"time" "time"
"github.com/prometheus/client_golang/prometheus/promhttp"
"github.com/stretchr/testify/assert" "github.com/stretchr/testify/assert"
compbasemetrics "k8s.io/component-base/metrics" compbasemetrics "k8s.io/component-base/metrics"
@ -33,6 +32,7 @@ import (
func TestRecordOperation(t *testing.T) { func TestRecordOperation(t *testing.T) {
// Use local registry // Use local registry
var registry = compbasemetrics.NewKubeRegistry() var registry = compbasemetrics.NewKubeRegistry()
var gather compbasemetrics.Gatherer = registry
defer registry.Reset() defer registry.Reset()
registry.MustRegister(metrics.RuntimeOperations) registry.MustRegister(metrics.RuntimeOperations)
registry.MustRegister(metrics.RuntimeOperationsDuration) registry.MustRegister(metrics.RuntimeOperationsDuration)
@ -44,7 +44,7 @@ func TestRecordOperation(t *testing.T) {
prometheusURL := "http://" + l.Addr().String() + "/metrics" prometheusURL := "http://" + l.Addr().String() + "/metrics"
mux := http.NewServeMux() mux := http.NewServeMux()
handler := promhttp.HandlerFor(registry, promhttp.HandlerOpts{}) handler := compbasemetrics.HandlerFor(gather, compbasemetrics.HandlerOpts{})
mux.Handle("/metrics", handler) mux.Handle("/metrics", handler)
server := &http.Server{ server := &http.Server{
Addr: l.Addr().String(), Addr: l.Addr().String(),