SEBA-973 Update kafka topic exporter to support voltha 2.0 KPI2 event types
Needs to be merged after mergeing VOL-2948
Change-Id: I29620969773d555294ce6eefe7cf52be6df63225
diff --git a/main.go b/main.go
index 752882b..6838cd7 100644
--- a/main.go
+++ b/main.go
@@ -71,23 +71,80 @@
err := http.ListenAndServe(":"+strconv.Itoa(target.Port), nil)
if err != nil {
logger.Error("HTTP Server Error: %s", err.Error())
- }
+ }
}
func init() {
// register metrics within Prometheus
- prometheus.MustRegister(volthaTxBytesTotal)
- prometheus.MustRegister(volthaRxBytesTotal)
- prometheus.MustRegister(volthaTxPacketsTotal)
- prometheus.MustRegister(volthaRxPacketsTotal)
- prometheus.MustRegister(volthaTxErrorPacketsTotal)
- prometheus.MustRegister(volthaRxErrorPacketsTotal)
+ prometheus.MustRegister(volthaOltTxBytesTotal)
+ prometheus.MustRegister(volthaOltRxBytesTotal)
+ prometheus.MustRegister(volthaOltTxPacketsTotal)
+ prometheus.MustRegister(volthaOltRxPacketsTotal)
+ prometheus.MustRegister(volthaOltTxErrorPacketsTotal)
+ prometheus.MustRegister(volthaOltRxErrorPacketsTotal)
+ prometheus.MustRegister(volthaOltTxBroadcastPacketsTotal)
+ prometheus.MustRegister(volthaOltTxUnicastPacketsTotal)
+ prometheus.MustRegister(volthaOltTxMulticastPacketsTotal)
+ prometheus.MustRegister(volthaOltRxBroadcastPacketsTotal)
+ prometheus.MustRegister(volthaOltRxUnicastPacketsTotal)
+ prometheus.MustRegister(volthaOltRxMulticastPacketsTotal)
prometheus.MustRegister(VolthaOnuLaserBiasCurrent)
prometheus.MustRegister(volthaOnuTemperature)
prometheus.MustRegister(VolthaOnuPowerFeedVoltage)
prometheus.MustRegister(VolthaOnuMeanOpticalLaunchPower)
prometheus.MustRegister(VolthaOnuReceivedOpticalPower)
+ prometheus.MustRegister(VolthaOnuTransmtOpticalPower)
+
+ prometheus.MustRegister(volthaOnuFecCorrectedCodewordsTotal)
+ prometheus.MustRegister(volthaOnuFecCodewordsTotal)
+ prometheus.MustRegister(volthaOnuFecCorrectedBytesTotal)
+ prometheus.MustRegister(volthaOnuFecSecondsTotal)
+ prometheus.MustRegister(volthaOnuFecUncorrectablewordsTotal)
+
+ prometheus.MustRegister(volthaEthernetUniSingleCollisionTotal)
+ prometheus.MustRegister(volthaEthernetUniMacLayerTramsmitErrorTotal)
+ prometheus.MustRegister(volthaEthernetUniMultiCollisionTotal)
+ prometheus.MustRegister(volthaEthernetUniFramestooLongTotal)
+ prometheus.MustRegister(volthaEthernetUniAlignmentErrorTotal)
+ prometheus.MustRegister(volthaEthernetUniCarrierErrorTotal)
+ prometheus.MustRegister(volthaEthernetUniExcessiveCollisionErrorTotal)
+ prometheus.MustRegister(volthaEthernetUniDeferredTxTotal)
+ prometheus.MustRegister(volthaEthernetUniLateCollisionTotal)
+ prometheus.MustRegister(volthaEthernetUniBufferOverflowsRxErrorTotal)
+ prometheus.MustRegister(volthaEthernetUniFcsErrorTotal)
+ prometheus.MustRegister(volthaEthernetUniSqeErrorTotal)
+ prometheus.MustRegister(volthaEthernetUniBufferOverflowsTxErrorTotal)
+
+ prometheus.MustRegister(volthaOnuBridgePortRxBytesTotal)
+ prometheus.MustRegister(volthaOnuBridgePortRxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_64octetRxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_65_127_octetRxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_128_255_octetRxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_256_511_octetRxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_512_1023_octetRxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_1024_1518_octetRxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortRxMulticastPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortRxBroadcastPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortRxOversizePacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortRxCrcErrorPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortRxUndersizePacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortRxDropEventsTotal)
+
+ prometheus.MustRegister(volthaOnuBridgePortTxBytesTotal)
+ prometheus.MustRegister(volthaOnuBridgePortTxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_64octetTxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_65_127_octetTxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_128_255_octetTxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_256_511_octetTxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_512_1023_octetTxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePort_1024_1518_octetTxPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortTxMulticastPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortTxBroadcastPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortTxOversizePacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortTxCrcErrorPacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortTxUndersizePacketsTotal)
+ prometheus.MustRegister(volthaOnuBridgePortTxDropEventsTotal)
prometheus.MustRegister(onosTxBytesTotal)
prometheus.MustRegister(onosRxBytesTotal)
@@ -134,7 +191,7 @@
prometheus.MustRegister(onosaaaEapPktTxAuthChooseEap)
prometheus.MustRegister(onosaaaTxRespnotNak)
- prometheus.MustRegister(onosaaaEapolFramesTx)
+ prometheus.MustRegister(onosaaaEapolFramesTx)
prometheus.MustRegister(onosaaaAuthStateIdle)
prometheus.MustRegister(onosaaaRequestIdFramesTx)
prometheus.MustRegister(onosaaaRequestEapFramesTx)