github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 18:00:08 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #130236 from adrianmoisey/add-test-for-deleted-entries-metric

Browse Source 
Add test for ReconcileConntrackFlowsDeletedEntriesTotal metric
This commit is contained in:
Kubernetes Prow Robot 2025-03-03 00:58:57 -08:00 committed by GitHub
commit 12e274b261
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/proxy/conntrack/cleanup_test.go
View File

@ -34,7 +34,10 @@ import (
discovery "k8s.io/api/discovery/v1" discovery "k8s.io/api/discovery/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/types"
"k8s.io/component-base/metrics/legacyregistry"
"k8s.io/component-base/metrics/testutil"
"k8s.io/kubernetes/pkg/proxy" "k8s.io/kubernetes/pkg/proxy"
"k8s.io/kubernetes/pkg/proxy/metrics"
netutils "k8s.io/utils/net" netutils "k8s.io/utils/net"
"k8s.io/utils/ptr" "k8s.io/utils/ptr"
) )
@ -306,9 +309,15 @@ func TestCleanStaleEntries(t *testing.T) {
t.Logf("entries before cleanup %d after cleanup %d", len(entriesBeforeCleanup), len(entriesAfterCleanup)) t.Logf("entries before cleanup %d after cleanup %d", len(entriesBeforeCleanup), len(entriesAfterCleanup))
fake := NewFake() fake := NewFake()
fake.entries = entriesBeforeCleanup fake.entries = entriesBeforeCleanup
CleanStaleEntries(fake, testIPFamily, svcPortMap, endpointsMap)
legacyregistry.MustRegister(metrics.ReconcileConntrackFlowsDeletedEntriesTotal)
CleanStaleEntries(fake, testIPFamily, svcPortMap, endpointsMap)
actualEntries, _ := fake.ListEntries(ipFamilyMap[testIPFamily]) actualEntries, _ := fake.ListEntries(ipFamilyMap[testIPFamily])
metricCount, err := testutil.GetCounterMetricValue(metrics.ReconcileConntrackFlowsDeletedEntriesTotal.WithLabelValues(string(testIPFamily)))
require.NoError(t, err)
require.Equal(t, int(metricCount), len(entriesBeforeCleanup)-len(entriesAfterCleanup))
require.Equal(t, len(entriesAfterCleanup), len(actualEntries)) require.Equal(t, len(entriesAfterCleanup), len(actualEntries))
// sort the actual flows before comparison // sort the actual flows before comparison