From 47e51f1270385195147b168cc1f4e66e61d5f2f9 Mon Sep 17 00:00:00 2001 From: Clive Jevons Date: Tue, 26 Jul 2022 14:14:22 +0200 Subject: [PATCH] move registerer check into metrics wrapper method --- pkg/iptables/iptables.go | 12 ++---------- pkg/iptables/metrics.go | 4 ++++ 2 files changed, 6 insertions(+), 10 deletions(-) diff --git a/pkg/iptables/iptables.go b/pkg/iptables/iptables.go index 99c5613..4cad47c 100644 --- a/pkg/iptables/iptables.go +++ b/pkg/iptables/iptables.go @@ -275,11 +275,7 @@ func New(opts ...ControllerOption) (*Controller, error) { if err != nil { return nil, fmt.Errorf("failed to create iptables IPv4 client: %v", err) } - if c.registerer != nil { - c.v4 = wrapWithMetrics(v4, "IPv4", c.registerer) - } else { - c.v4 = v4 - } + c.v4 = wrapWithMetrics(v4, "IPv4", c.registerer) } if c.v6 == nil { disabled, err := ipv6Disabled() @@ -294,11 +290,7 @@ func New(opts ...ControllerOption) (*Controller, error) { if err != nil { return nil, fmt.Errorf("failed to create iptables IPv6 client: %v", err) } - if c.registerer != nil { - c.v6 = wrapWithMetrics(v6, "IPv6", c.registerer) - } else { - c.v6 = v6 - } + c.v6 = wrapWithMetrics(v6, "IPv6", c.registerer) } } return c, nil diff --git a/pkg/iptables/metrics.go b/pkg/iptables/metrics.go index bb977fe..b262937 100644 --- a/pkg/iptables/metrics.go +++ b/pkg/iptables/metrics.go @@ -24,6 +24,10 @@ type metricsClientWrapper struct { } func wrapWithMetrics(client Client, protocol string, registerer prometheus.Registerer) Client { + if registerer == nil { + return client + } + labelNames := []string{ "operation", "table",