Relfect reviews

Signed-off-by: terashima <tomoya-terashima@cybozu.co.jp>

Author: terassyi

docs/cmd-coil-egress.md

@@ -84,7 +84,7 @@ This value is from the result of `iptables -t nat -L POSTROUTING -vn`.
 | `namespace` | The egress resource namespace |
 | `egress`    | The egress resource name      |
 | `pod`       | The pod name                  |
-| `protocol`  | Protocol name                 |
+| `protocol`  | The protocol name                 |
 
 ### `coil_egress_nftables_masqueraded_bytes_total`
 
@@ -96,7 +96,7 @@ This value is from the result of `iptables -t nat -L POSTROUTING -vn`.
 | `namespace` | The egress resource namespace |
 | `egress`    | The egress resource name      |
 | `pod`       | The pod name                  |
-| `protocol`  | Protocol name                 |
+| `protocol`  | The protocol name                 |
 
 ### `coil_egress_nftables_invalid_packets_total`
 
@@ -108,7 +108,7 @@ This value is from the result of `iptables -t filter -L -vn`.
 | `namespace` | The egress resource namespace |
 | `egress`    | The egress resource name      |
 | `pod`       | The pod name                  |
-| `protocol`  | Protocol name                 |
+| `protocol`  | The protocol name                 |
 
 ### `coil_egress_nftables_invalid_bytes_total`
 
@@ -120,5 +120,5 @@ This value is from the result of `iptables -t filter -L -vn`.
 | `namespace` | The egress resource namespace |
 | `egress`    | The egress resource name      |
 | `pod`       | The pod name                  |
-| `protocol`  | Protocol name                 |
+| `protocol`  | The protocol name                 |
 

v2/cmd/coil-egress/sub/run.go

@@ -25,6 +25,8 @@ import (
 
 const (
 	gracefulTimeout = 5 * time.Second
+	protocolIPv4    = "ipv4"
+	protocolIpv6    = "ipv6"
 )
 
 var (
@@ -37,8 +39,8 @@ func init() {
 
 	// +kubebuilder:scaffold:scheme
 
-	metrics.Registry.MustRegister(egressMetrics.NfConnctrackCount)
-	metrics.Registry.MustRegister(egressMetrics.NfConnctrackLimit)
+	metrics.Registry.MustRegister(egressMetrics.NfConntrackCount)
+	metrics.Registry.MustRegister(egressMetrics.NfConntrackLimit)
 	metrics.Registry.MustRegister(egressMetrics.NfTableMasqueradeBytes)
 	metrics.Registry.MustRegister(egressMetrics.NfTableMasqueradePackets)
 	metrics.Registry.MustRegister(egressMetrics.NfTableInvalidBytes)
@@ -71,10 +73,10 @@ func subMain() error {
 		}
 		if n4 := n.To4(); n4 != nil {
 			ipv4 = n4
-			protocolMap["ipv4"] = struct{}{}
+			protocolMap[protocolIPv4] = struct{}{}
 		} else {
 			ipv6 = n
-			protocolMap["ipv6"] = struct{}{}
+			protocolMap[protocolIpv6] = struct{}{}
 		}
 	}
 
@@ -83,7 +85,7 @@ func subMain() error {
 		protocols = append(protocols, protocol)
 	}
 
-	setupLog.Info("detected local IP addresses", "ipv4", ipv4.String(), "ipv6", ipv6.String())
+	setupLog.Info("detected local IP addresses", protocolIPv4, ipv4.String(), protocolIpv6, ipv6.String())
 
 	timeout := gracefulTimeout
 	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
@@ -106,13 +108,13 @@ func subMain() error {
 		return err
 	}
 
-	setupLog.Info("initialize FoU tunnel", "port", config.port, "ipv4", ipv4.String(), "ipv6", ipv6.String())
+	setupLog.Info("initialize FoU tunnel", "port", config.port, protocolIPv4, ipv4.String(), protocolIpv6, ipv6.String())
 	ft := founat.NewFoUTunnel(config.port, ipv4, ipv6, nil)
 	if err := ft.Init(); err != nil {
 		return err
 	}
 
-	setupLog.Info("initialize Egress", "ipv4", ipv4.String(), "ipv6", ipv6.String())
+	setupLog.Info("initialize Egress", protocolIPv4, ipv4.String(), protocolIpv6, ipv6.String())
 	eg := founat.NewEgress("eth0", ipv4, ipv6)
 	if err := eg.Init(); err != nil {
 		return err

v2/pkg/metrics/egress.go

@@ -20,14 +20,14 @@ const (
 )
 
 var (
-	NfConnctrackCount = prometheus.NewGaugeVec(prometheus.GaugeOpts{
+	NfConntrackCount = prometheus.NewGaugeVec(prometheus.GaugeOpts{
 		Namespace: constants.MetricsNS,
 		Subsystem: "egress",
 		Name:      "nf_conntrack_entries_count",
 		Help:      "the number of entries in the nf_conntrack table",
 	}, []string{"namespace", "pod", "egress"})
 
-	NfConnctrackLimit = prometheus.NewGaugeVec(prometheus.GaugeOpts{
+	NfConntrackLimit = prometheus.NewGaugeVec(prometheus.GaugeOpts{
 		Namespace: constants.MetricsNS,
 		Subsystem: "egress",
 		Name:      "nf_conntrack_entries_limit",
@@ -71,24 +71,24 @@ type egressCollector struct {
 }
 
 type nfTablesPerProtocolMetrics struct {
-	nfTablesNATPackets     prometheus.Gauge
-	nfTablesNATBytes       prometheus.Gauge
-	nfTablesInvalidPackets prometheus.Gauge
-	nfTablesInvalidBytes   prometheus.Gauge
+	NATPackets     prometheus.Gauge
+	NATBytes       prometheus.Gauge
+	InvalidPackets prometheus.Gauge
+	InvalidBytes   prometheus.Gauge
 }
 
 func newNfTablesPerProtocolMetrics(ns, pod, egress, protocol string) *nfTablesPerProtocolMetrics {
 	return &nfTablesPerProtocolMetrics{
-		nfTablesNATPackets:     NfTableMasqueradePackets.WithLabelValues(ns, pod, egress, protocol),
-		nfTablesNATBytes:       NfTableMasqueradeBytes.WithLabelValues(ns, pod, egress, protocol),
-		nfTablesInvalidPackets: NfTableInvalidPackets.WithLabelValues(ns, pod, egress, protocol),
-		nfTablesInvalidBytes:   NfTableInvalidBytes.WithLabelValues(ns, pod, egress, protocol),
+		NATPackets:     NfTableMasqueradePackets.WithLabelValues(ns, pod, egress, protocol),
+		NATBytes:       NfTableMasqueradeBytes.WithLabelValues(ns, pod, egress, protocol),
+		InvalidPackets: NfTableInvalidPackets.WithLabelValues(ns, pod, egress, protocol),
+		InvalidBytes:   NfTableInvalidBytes.WithLabelValues(ns, pod, egress, protocol),
 	}
 }
 
 func NewEgressCollector(ns, pod, egress string, protocols []string) (Collector, error) {
-	NfConnctrackCount.Reset()
-	NfConnctrackLimit.Reset()
+	NfConntrackCount.Reset()
+	NfConntrackLimit.Reset()
 	NfTableMasqueradeBytes.Reset()
 	NfTableMasqueradePackets.Reset()
 	NfTableInvalidPackets.Reset()
@@ -106,8 +106,8 @@ func NewEgressCollector(ns, pod, egress string, protocols []string) (Collector,
 
 	return &egressCollector{
 		conn:              c,
-		nfConnctrackCount: NfConnctrackCount.WithLabelValues(ns, pod, egress),
-		nfConnctrackLimit: NfConnctrackLimit.WithLabelValues(ns, pod, egress),
+		nfConnctrackCount: NfConntrackCount.WithLabelValues(ns, pod, egress),
+		nfConnctrackLimit: NfConntrackLimit.WithLabelValues(ns, pod, egress),
 		perProtocol:       perProtocols,
 	}, nil
 }
@@ -135,15 +135,15 @@ func (c *egressCollector) Update(ctx context.Context) error {
 		if err != nil {
 			return err
 		}
-		nfTablesMetrics.nfTablesNATPackets.Set(float64(natPackets))
-		nfTablesMetrics.nfTablesNATBytes.Set(float64(natBytes))
+		nfTablesMetrics.NATPackets.Set(float64(natPackets))
+		nfTablesMetrics.NATBytes.Set(float64(natBytes))
 
 		invalidPackets, invalidBytes, err := c.getNfTablesInvalidCounter(protocol)
 		if err != nil {
 			return err
 		}
-		nfTablesMetrics.nfTablesInvalidPackets.Set(float64(invalidPackets))
-		nfTablesMetrics.nfTablesInvalidBytes.Set(float64(invalidBytes))
+		nfTablesMetrics.InvalidPackets.Set(float64(invalidPackets))
+		nfTablesMetrics.InvalidBytes.Set(float64(invalidBytes))
 
 	}