github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-31 15:25:57 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #100218 from aojea/unitflakes1

Browse Source 
unit test using metrics must reset the global registry
This commit is contained in:
Kubernetes Prow Robot 2021-04-29 23:01:57 -07:00 committed by GitHub
commit 6850e0abf2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/kubelet/dockershim/network/plugins_test.go
View File

@ -30,6 +30,7 @@ import (
func TestNetworkPluginManagerMetrics(t *testing.T) {
metrics.Register()
defer legacyregistry.Reset()
operation := "test_operation"
recordOperation(operation, time.Now())

14
staging/src/k8s.io/apiserver/pkg/admission/metrics/metrics_test.go
View File

@ -26,6 +26,7 @@ import (
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/apiserver/pkg/admission"
"k8s.io/component-base/metrics/legacyregistry"
)
var (
@ -35,7 +36,8 @@ var (
)
func TestObserveAdmissionStep(t *testing.T) {
Metrics.reset()
defer Metrics.reset()
defer legacyregistry.Reset()
handler := WithStepMetrics(&mutatingAndValidatingFakeHandler{admission.NewHandler(admission.Create), true, true})
if err := handler.(admission.MutationInterface).Admit(context.TODO(), attr, nil); err != nil {
t.Errorf("Unexpected error in admit: %v", err)
@ -57,7 +59,8 @@ func TestObserveAdmissionStep(t *testing.T) {
}
func TestObserveAdmissionController(t *testing.T) {
Metrics.reset()
defer Metrics.reset()
defer legacyregistry.Reset()
handler := WithControllerMetrics(&mutatingAndValidatingFakeHandler{admission.NewHandler(admission.Create), true, true}, "a")
if err := handler.(admission.MutationInterface).Admit(context.TODO(), attr, nil); err != nil {
t.Errorf("Unexpected error in admit: %v", err)
@ -78,7 +81,8 @@ func TestObserveAdmissionController(t *testing.T) {
}
func TestObserveWebhook(t *testing.T) {
Metrics.reset()
defer Metrics.reset()
defer legacyregistry.Reset()
Metrics.ObserveWebhook(context.TODO(), 2*time.Second, false, attr, stepAdmit, "x")
wantLabels := map[string]string{
"name": "x",
@ -121,8 +125,8 @@ func TestObserveWebhookRejection(t *testing.T) {
}
func TestWithMetrics(t *testing.T) {
Metrics.reset()
defer Metrics.reset()
defer legacyregistry.Reset()
type Test struct {
name string
ns string