VOL-3705 Create option in kafka-topic-export to report ONU serial no in metrics in Hex format instead of ASCII chars
Change-Id: Id54f729efe4f9fee2accb3b18e97328b5e5db1ca
diff --git a/topic-exporter.go b/topic-exporter.go
index c0615b9..4e11118 100644
--- a/topic-exporter.go
+++ b/topic-exporter.go
@@ -20,6 +20,7 @@
"strings"
"gerrit.opencord.org/kafka-topic-exporter/common/logger"
+ "gerrit.opencord.org/kafka-topic-exporter/utils"
"github.com/golang/protobuf/proto"
"github.com/opencord/device-management-interface/go/dmi"
"github.com/opencord/voltha-protos/go/voltha"
@@ -1057,204 +1058,207 @@
}
func exportVolthaOnuEthernetBridgePortStats(data *voltha.MetricInformation) {
-
+ onuSN := utils.GetOnuSN(data.GetMetadata().GetSerialNo())
if (data.GetMetadata().GetContext()["upstream"]) == "True" {
// ONU. Extended Ethernet statistics.
+
+
volthaOnuBridgePortTxPacketsTotal.WithLabelValues(
data.Metadata.GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["packets"]))
volthaOnuBridgePortTxBytesTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["octets"]))
volthaOnuBridgePort_64octetTxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["64_octets"]))
volthaOnuBridgePort_65_127_octetTxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["65_to_127_octets"]))
volthaOnuBridgePort_128_255_octetTxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["128_to_255_octets"]))
volthaOnuBridgePort_256_511_octetTxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["256_to_511_octets"]))
volthaOnuBridgePort_512_1023_octetTxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["512_to_1023_octets"]))
volthaOnuBridgePort_1024_1518_octetTxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["1024_to_1518_octets"]))
volthaOnuBridgePortTxMulticastPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["multicast_packets"]))
volthaOnuBridgePortTxBroadcastPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["broadcast_packets"]))
volthaOnuBridgePortTxOversizePacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["oversize_packets"]))
volthaOnuBridgePortTxCrcErrorPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["crc_errored_packets"]))
volthaOnuBridgePortTxUndersizePacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["undersize_packets"]))
volthaOnuBridgePortTxDropEventsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["drop_events"]))
} else {
+
// ONU. Extended Ethernet statistics.
volthaOnuBridgePortRxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["packets"]))
volthaOnuBridgePortRxBytesTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["octets"]))
volthaOnuBridgePort_64octetRxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["64_octets"]))
volthaOnuBridgePort_65_127_octetRxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["65_to_127_octets"]))
volthaOnuBridgePort_128_255_octetRxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["128_to_255_octets"]))
volthaOnuBridgePort_256_511_octetRxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["256_to_511_octets"]))
volthaOnuBridgePort_512_1023_octetRxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["512_to_1023_octets"]))
volthaOnuBridgePort_1024_1518_octetRxPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["1024_to_1518_octets"]))
volthaOnuBridgePortRxMulticastPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["multicast_packets"]))
volthaOnuBridgePortRxBroadcastPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["broadcast_packets"]))
volthaOnuBridgePortRxOversizePacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["oversize_packets"]))
volthaOnuBridgePortRxCrcErrorPacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["crc_errored_packets"]))
volthaOnuBridgePortRxUndersizePacketsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["undersize_packets"]))
volthaOnuBridgePortRxDropEventsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.Metadata.GetSerialNo(),
+ onuSN,
data.Metadata.GetDeviceId(),
data.GetMetadata().GetTitle(),
).Add(float64(data.GetMetrics()["drop_events"]))
@@ -1263,9 +1267,10 @@
}
func exportVolthaOnuPonOpticalStats(data *voltha.MetricInformation) {
+ onuSN := utils.GetOnuSN(data.GetMetadata().GetSerialNo())
VolthaOnuTransmtOpticalPower.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
"NA", // PonID,
@@ -1275,7 +1280,7 @@
VolthaOnuReceivedOpticalPower.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
"NA", // PonID,
@@ -1284,46 +1289,48 @@
).Set(float64(data.GetMetrics()["receive_power"]))
}
func exportVolthaOnuFecStats(data *voltha.MetricInformation) {
+ onuSN := utils.GetOnuSN(data.GetMetadata().GetSerialNo())
volthaOnuFecCorrectedCodewordsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Set(float64(data.GetMetrics()["corrected_code_words"]))
volthaOnuFecCodewordsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Set(float64(data.GetMetrics()["total_code_words"]))
volthaOnuFecCorrectedBytesTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Set(float64(data.GetMetrics()["corrected_bytes"]))
volthaOnuFecSecondsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Set(float64(data.GetMetrics()["fec_seconds"]))
volthaOnuFecUncorrectablewordsTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetTitle(),
).Set(float64(data.GetMetrics()["uncorrectable_code_words"]))
}
func exportVolthaOnuEthernetUniStats(data *voltha.MetricInformation) {
+ onuSN := utils.GetOnuSN(data.GetMetadata().GetSerialNo())
volthaEthernetUniSingleCollisionTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1332,7 +1339,7 @@
volthaEthernetUniMacLayerTramsmitErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1341,7 +1348,7 @@
volthaEthernetUniMultiCollisionTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1350,7 +1357,7 @@
volthaEthernetUniFramestooLongTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1358,7 +1365,7 @@
).Set(float64(data.GetMetrics()["frames_too_long"]))
volthaEthernetUniAlignmentErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1367,7 +1374,7 @@
volthaEthernetUniCarrierErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1375,7 +1382,7 @@
).Set(float64(data.GetMetrics()["carrier_sense_error_counter"]))
volthaEthernetUniExcessiveCollisionErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1384,7 +1391,7 @@
volthaEthernetUniDeferredTxTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1393,7 +1400,7 @@
volthaEthernetUniLateCollisionTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1402,7 +1409,7 @@
volthaEthernetUniBufferOverflowsRxErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1411,7 +1418,7 @@
volthaEthernetUniFcsErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1420,7 +1427,7 @@
volthaEthernetUniSqeErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],
@@ -1429,7 +1436,7 @@
volthaEthernetUniBufferOverflowsTxErrorTotal.WithLabelValues(
data.GetMetadata().GetLogicalDeviceId(),
- data.GetMetadata().GetSerialNo(),
+ onuSN,
data.GetMetadata().GetDeviceId(),
data.GetMetadata().GetContext()["intf_id"],
data.GetMetadata().GetContext()["portno"],