diff --git a/utils/metrics.go b/utils/metrics.go index 585923c..eb3f231 100644 --- a/utils/metrics.go +++ b/utils/metrics.go @@ -13,14 +13,14 @@ var ( Name: "flow_traffic_bytes", Help: "Bytes received by the application.", }, - []string{"remote_ip", "remote_port", "local_ip", "local_port", "type"}, + []string{"remote_ip", "local_ip", "local_port", "type"}, ) MetricTrafficPackets = prometheus.NewCounterVec( prometheus.CounterOpts{ Name: "flow_traffic_packets", Help: "Packets received by the application.", }, - []string{"remote_ip", "remote_port", "local_ip", "local_port", "type"}, + []string{"remote_ip", "local_ip", "local_port", "type"}, ) MetricPacketSizeSum = prometheus.NewSummaryVec( prometheus.SummaryOpts{ @@ -28,7 +28,7 @@ var ( Help: "Summary of packet size.", Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.99: 0.001}, }, - []string{"remote_ip", "remote_port", "local_ip", "local_port", "type"}, + []string{"remote_ip", "local_ip", "local_port", "type"}, ) DecoderStats = prometheus.NewCounterVec( prometheus.CounterOpts{ diff --git a/utils/utils.go b/utils/utils.go index 3796729..de2855c 100644 --- a/utils/utils.go +++ b/utils/utils.go @@ -316,7 +316,6 @@ func UDPRoutine(name string, decodeFunc decoder.DecoderFunc, workers int, addr s MetricTrafficBytes.With( prometheus.Labels{ "remote_ip": pktAddr.IP.String(), - "remote_port": strconv.Itoa(pktAddr.Port), "local_ip": localIP, "local_port": strconv.Itoa(addrUDP.Port), "type": name, @@ -325,7 +324,6 @@ func UDPRoutine(name string, decodeFunc decoder.DecoderFunc, workers int, addr s MetricTrafficPackets.With( prometheus.Labels{ "remote_ip": pktAddr.IP.String(), - "remote_port": strconv.Itoa(pktAddr.Port), "local_ip": localIP, "local_port": strconv.Itoa(addrUDP.Port), "type": name, @@ -334,7 +332,6 @@ func UDPRoutine(name string, decodeFunc decoder.DecoderFunc, workers int, addr s MetricPacketSizeSum.With( prometheus.Labels{ "remote_ip": pktAddr.IP.String(), - "remote_port": strconv.Itoa(pktAddr.Port), "local_ip": localIP, "local_port": strconv.Itoa(addrUDP.Port), "type": name,