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

kube-proxy: metric to track entries deleted in conntrack reconciliation

Browse Source 
kubeproxy_conntrack_reconciler_deleted_entries_total can be used
to track total entries deleted in conntrack reconciliation.

Signed-off-by: Daman Arora <aroradaman@gmail.com>
This commit is contained in:
Daman Arora 2025-02-16 21:37:23 +05:30
parent edc1fd24cc
commit 438df173e3
2 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/proxy/conntrack/cleanup.go
View File

@ -116,12 +116,14 @@ func CleanStaleEntries(ct Interface, ipFamily v1.IPFamily,
}
}
if n, err := ct.ClearEntries(ipFamilyMap[ipFamily], filters...); err != nil {
var n int
if n, err = ct.ClearEntries(ipFamilyMap[ipFamily], filters...); err != nil {
klog.ErrorS(err, "Failed to clear all conntrack entries", "ipFamily", ipFamily, "entriesDeleted", n, "took", time.Since(start))
} else {
klog.V(4).InfoS("Finished reconciling conntrack entries", "ipFamily", ipFamily, "entriesDeleted", n, "took", time.Since(start))
}
metrics.ReconcileConntrackFlowsLatency.WithLabelValues(string(ipFamily)).Observe(metrics.SinceInSeconds(start))
metrics.ReconcileConntrackFlowsDeletedEntriesTotal.WithLabelValues(string(ipFamily)).Add(float64(n))
}
// ipFamilyMap maps v1.IPFamily to the corresponding unix constant.

14
pkg/proxy/metrics/metrics.go
View File

@ -295,6 +295,17 @@ var (
},
[]string{"ip_family"},
)
// ReconcileConntrackFlowsDeletedEntriesTotal is the number of entries deleted by conntrack reconciler.
ReconcileConntrackFlowsDeletedEntriesTotal = metrics.NewCounterVec(
&metrics.CounterOpts{
Subsystem: kubeProxySubsystem,
Name: "conntrack_reconciler_deleted_entries_total",
Help: "Cumulative conntrack flows deleted by conntrack reconciler",
StabilityLevel: metrics.ALPHA,
},
[]string{"ip_family"},
)
)
var registerMetricsOnce sync.Once
@ -334,10 +345,12 @@ func RegisterMetrics(mode kubeproxyconfig.ProxyMode) {
legacyregistry.MustRegister(IPTablesRulesTotal)
legacyregistry.MustRegister(IPTablesRulesLastSync)
legacyregistry.MustRegister(ReconcileConntrackFlowsLatency)
legacyregistry.MustRegister(ReconcileConntrackFlowsDeletedEntriesTotal)
case kubeproxyconfig.ProxyModeIPVS:
legacyregistry.MustRegister(IPTablesRestoreFailuresTotal)
legacyregistry.MustRegister(ReconcileConntrackFlowsLatency)
legacyregistry.MustRegister(ReconcileConntrackFlowsDeletedEntriesTotal)
case kubeproxyconfig.ProxyModeNFTables:
legacyregistry.MustRegister(SyncFullProxyRulesLatency)
@ -345,6 +358,7 @@ func RegisterMetrics(mode kubeproxyconfig.ProxyMode) {
legacyregistry.MustRegister(NFTablesSyncFailuresTotal)
legacyregistry.MustRegister(NFTablesCleanupFailuresTotal)
legacyregistry.MustRegister(ReconcileConntrackFlowsLatency)
legacyregistry.MustRegister(ReconcileConntrackFlowsDeletedEntriesTotal)
case kubeproxyconfig.ProxyModeKernelspace:
// currently no winkernel-specific metrics