| // Copyright 2018 Open Networking Foundation |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| package main |
| |
| import ( |
| "encoding/json" |
| "gerrit.opencord.org/kafka-topic-exporter/common/logger" |
| "github.com/prometheus/client_golang/prometheus" |
| log "github.com/sirupsen/logrus" |
| "strconv" |
| "strings" |
| ) |
| |
| var ( |
| // voltha kpis |
| volthaTxBytesTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_tx_bytes_total", |
| Help: "Number of total bytes transmitted", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| volthaRxBytesTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_rx_bytes_total", |
| Help: "Number of total bytes received", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| volthaTxPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_tx_packets_total", |
| Help: "Number of total packets transmitted", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| volthaRxPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_rx_packets_total", |
| Help: "Number of total packets received", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| volthaTxErrorPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_tx_error_packets_total", |
| Help: "Number of total transmitted packets error", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| volthaRxErrorPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_rx_error_packets_total", |
| Help: "Number of total received packets error", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| // optical parameters |
| VolthaOnuLaserBiasCurrent = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_onu_laser_bias_current", |
| Help: "ONU Laser bias current value", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| volthaOnuTemperature = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_onu_temperature", |
| Help: "ONU temperature value", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| VolthaOnuPowerFeedVoltage = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_onu_power_feed_voltage", |
| Help: "ONU power feed voltage", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| VolthaOnuMeanOpticalLaunchPower = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_onu_mean_optical_launch_power", |
| Help: "ONU mean optical launch power", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| VolthaOnuReceivedOpticalPower = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "voltha_onu_received_optical_power", |
| Help: "ONU received optical power", |
| }, |
| []string{"logical_device_id", "serial_number", "device_id", "interface_id", "pon_id", "port_number", "title"}, |
| ) |
| |
| // onos kpis |
| onosTxBytesTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onos_tx_bytes_total", |
| Help: "Number of total bytes transmitted", |
| }, |
| []string{"device_id", "port_id"}, |
| ) |
| onosRxBytesTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onos_rx_bytes_total", |
| Help: "Number of total bytes received", |
| }, |
| []string{"device_id", "port_id"}, |
| ) |
| onosTxPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onos_tx_packets_total", |
| Help: "Number of total packets transmitted", |
| }, |
| []string{"device_id", "port_id"}, |
| ) |
| onosRxPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onos_rx_packets_total", |
| Help: "Number of total packets received", |
| }, |
| []string{"device_id", "port_id"}, |
| ) |
| |
| onosTxDropPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onos_tx_drop_packets_total", |
| Help: "Number of total transmitted packets dropped", |
| }, |
| []string{"device_id", "port_id"}, |
| ) |
| |
| onosRxDropPacketsTotal = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onos_rx_drop_packets_total", |
| Help: "Number of total received packets dropped", |
| }, |
| []string{"device_id", "port_id"}, |
| ) |
| |
| // onos.aaa kpis |
| onosaaaRxAcceptResponses = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_accept_responses", |
| Help: "Number of access accept packets received from the server", |
| }) |
| onosaaaRxRejectResponses = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_reject_responses", |
| Help: "Number of access reject packets received from the server", |
| }) |
| onosaaaRxChallengeResponses = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_challenge_response", |
| Help: "Number of access challenge packets received from the server", |
| }) |
| onosaaaTxAccessRequests = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_tx_access_requests", |
| Help: "Number of access request packets sent to the server", |
| }) |
| onosaaaRxInvalidValidators = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_invalid_validators", |
| Help: "Number of access response packets received from the server with an invalid validator", |
| }) |
| onosaaaRxUnknownType = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_unknown_type", |
| Help: "Number of packets of an unknown RADIUS type received from the accounting server", |
| }) |
| onosaaaPendingRequests = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_pending_responses", |
| Help: "Number of access request packets pending a response from the server", |
| }) |
| onosaaaRxDroppedResponses = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_dropped_responses", |
| Help: "Number of dropped packets received from the accounting server", |
| }) |
| onosaaaRxMalformedResponses = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_malformed_responses", |
| Help: "Number of malformed access response packets received from the server", |
| }) |
| onosaaaRxUnknownserver = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_from_unknown_server", |
| Help: "Number of packets received from an unknown server", |
| }) |
| onosaaaRequestRttMillis = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_request_rttmillis", |
| Help: "Roundtrip packet time to the accounting server in Miliseconds", |
| }) |
| onosaaaRequestReTx = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_request_re_tx", |
| Help: "Number of access request packets retransmitted to the server", |
| }) |
| |
| // ONOS PPPoE kpis |
| |
| onosPppoeUpTermBytes = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoeupTermBytes", |
| Help: "onosPppoeupTermBytes", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeUpTermPackets = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoeupTermPackets", |
| Help: "onosPppoeupTermPackets", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeUpDropBytes = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoeupDropBytes", |
| Help: "onosPppoeupDropBytes", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeUpDropPackets = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoeupDropPackets", |
| Help: "onosPppoeupDropPackets", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeUpControlPackets = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoeupControlPackets", |
| Help: "onosPppoeupControlPackets", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeDownRxBytes = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoedownRxBytes", |
| Help: "onosPppoedownRxBytes", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeDownRxPackets = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoedownRxPackets", |
| Help: "onosPppoedownRxPackets", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeDownTxBytes = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoedownTxBytes", |
| Help: "onosPppoedownTxBytes", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| onosPppoeDownTxPackets = prometheus.NewGaugeVec( |
| prometheus.GaugeOpts{ |
| Name: "onosPppoedownTxPackets", |
| Help: "onosPppoedownTxPackets", |
| }, |
| []string{"mac_address", "ip", "session_id", "s_tag", "c_tag", "onu_serial"}, |
| ) |
| deviceLaserBiasCurrent = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "device_laser_bias_current", |
| Help: "Device Laser Bias Current", |
| }) |
| deviceTemperature = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "device_temperature", |
| Help: "Device Temperature", |
| }) |
| deviceTxPower = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "device_tx_power", |
| Help: "Device Tx Power", |
| }) |
| deviceVoltage = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "device_voltage", |
| Help: "Device Voltage", |
| }) |
| onosaaaRxEapolLogoff = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_rx_eapol_Logoff", |
| Help: "Number of EAPOL logoff messages received resulting in disconnected state", |
| }) |
| onosaaaTxEapolResIdentityMsg = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_tx_eapol_Res_IdentityMsg", |
| Help: "Number of authenticating transitions due to EAP response or identity message", |
| }) |
| onosaaaTxAuthSuccess = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_tx_auth_Success", |
| Help: "Number of authenticated transitions due to successful authentication", |
| }) |
| onosaaaTxAuthFailure = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_tx_auth_Failure", |
| Help: "Number of transitions to held due to authentication failure", |
| }) |
| onosaaaTxStartReq = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_tx_start_Req", |
| Help: "Number of transitions to connecting due to start request", |
| }) |
| onosaaaEapPktTxAuthChooseEap = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_eap_Pkt_tx_auth_choosing_Eap", |
| Help: "Number of EAP request packets sent due to the authenticator choosing the EAP method", |
| }) |
| onosaaaTxRespnotNak = prometheus.NewGauge( |
| prometheus.GaugeOpts{ |
| Name: "onosaaa_tx_Resp_not_Nak", |
| Help: "Number of transitions to response (received response other that NAK)", |
| }) |
| ) |
| |
| func exportVolthaKPI(kpi VolthaKPI) { |
| |
| for _, data := range kpi.SliceDatas { |
| switch title := data.Metadata.Title; title { |
| case "Ethernet", "PON": |
| volthaTxBytesTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.TxBytes) |
| |
| volthaRxBytesTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.RxBytes) |
| |
| volthaTxPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.TxPackets) |
| |
| volthaRxPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.RxPackets) |
| |
| volthaTxErrorPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.TxErrorPackets) |
| |
| volthaRxErrorPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.RxErrorPackets) |
| |
| // TODO add metrics for: |
| // TxBcastPackets |
| // TxUnicastPackets |
| // TxMulticastPackets |
| // RxBcastPackets |
| // RxMulticastPackets |
| |
| case "Ethernet_Bridge_Port_History": |
| if data.Metadata.Context.Upstream == "True" { |
| // ONU. Extended Ethernet statistics. |
| volthaTxPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| "NA", // InterfaceID |
| "NA", // PonID |
| "NA", // PortNumber |
| data.Metadata.Title, |
| ).Add(data.Metrics.Packets) |
| |
| volthaTxBytesTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| "NA", // InterfaceID |
| "NA", // PonID |
| "NA", // PortNumber |
| data.Metadata.Title, |
| ).Add(data.Metrics.Octets) |
| } else { |
| // ONU. Extended Ethernet statistics. |
| volthaRxPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| "NA", // InterfaceID |
| "NA", // PonID |
| "NA", // PortNumber |
| data.Metadata.Title, |
| ).Add(data.Metrics.Packets) |
| |
| volthaRxBytesTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| "NA", // InterfaceID |
| "NA", // PonID |
| "NA", // PortNumber |
| data.Metadata.Title, |
| ).Add(data.Metrics.Octets) |
| } |
| |
| case "PON_Optical": |
| VolthaOnuLaserBiasCurrent.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.LaserBiasCurrent) |
| |
| volthaOnuTemperature.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.Temperature) |
| |
| VolthaOnuPowerFeedVoltage.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.PowerFeedVoltage) |
| |
| VolthaOnuMeanOpticalLaunchPower.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.MeanOpticalLaunchPower) |
| |
| VolthaOnuReceivedOpticalPower.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.ReceivedOpticalPower) |
| |
| case "Ethernet_UNI_History": |
| // ONU. Do nothing. |
| |
| case "FEC_History": |
| // ONU. Do Nothing. |
| |
| volthaTxBytesTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.TxBytes) |
| |
| volthaRxBytesTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.RxBytes) |
| |
| volthaTxPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.TxPackets) |
| |
| volthaRxPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.RxPackets) |
| |
| volthaTxErrorPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.TxErrorPackets) |
| |
| volthaRxErrorPacketsTotal.WithLabelValues( |
| data.Metadata.LogicalDeviceID, |
| data.Metadata.SerialNumber, |
| data.Metadata.DeviceID, |
| data.Metadata.Context.InterfaceID, |
| data.Metadata.Context.PonID, |
| data.Metadata.Context.PortNumber, |
| data.Metadata.Title, |
| ).Set(data.Metrics.RxErrorPackets) |
| |
| // TODO add metrics for: |
| // TxBcastPackets |
| // TxUnicastPackets |
| // TxMulticastPackets |
| // RxBcastPackets |
| // RxMulticastPackets |
| |
| case "voltha.internal": |
| // Voltha Internal. Do nothing. |
| } |
| } |
| } |
| |
| func exportOnosKPI(kpi OnosKPI) { |
| |
| for _, data := range kpi.Ports { |
| |
| onosTxBytesTotal.WithLabelValues( |
| kpi.DeviceID, |
| data.PortID, |
| ).Set(data.TxBytes) |
| |
| onosRxBytesTotal.WithLabelValues( |
| kpi.DeviceID, |
| data.PortID, |
| ).Set(data.RxBytes) |
| |
| onosTxPacketsTotal.WithLabelValues( |
| kpi.DeviceID, |
| data.PortID, |
| ).Set(data.TxPackets) |
| |
| onosRxPacketsTotal.WithLabelValues( |
| kpi.DeviceID, |
| data.PortID, |
| ).Set(data.RxPackets) |
| |
| onosTxDropPacketsTotal.WithLabelValues( |
| kpi.DeviceID, |
| data.PortID, |
| ).Set(data.TxPacketsDrop) |
| |
| onosRxDropPacketsTotal.WithLabelValues( |
| kpi.DeviceID, |
| data.PortID, |
| ).Set(data.RxPacketsDrop) |
| } |
| } |
| |
| func exportImporterKPI(kpi ImporterKPI) { |
| deviceLaserBiasCurrent.Set(kpi.LaserBiasCurrent) |
| deviceTemperature.Set(kpi.Temperature) |
| deviceTxPower.Set(kpi.TxPower) |
| deviceVoltage.Set(kpi.Voltage) |
| } |
| |
| func exportOnosAaaKPI(kpi OnosAaaKPI) { |
| |
| onosaaaRxAcceptResponses.Set(kpi.RxAcceptResponses) |
| |
| onosaaaRxRejectResponses.Set(kpi.RxRejectResponses) |
| |
| onosaaaRxChallengeResponses.Set(kpi.RxChallengeResponses) |
| |
| onosaaaTxAccessRequests.Set(kpi.TxAccessRequests) |
| |
| onosaaaRxInvalidValidators.Set(kpi.RxInvalidValidators) |
| |
| onosaaaRxUnknownType.Set(kpi.RxUnknownType) |
| |
| onosaaaPendingRequests.Set(kpi.PendingRequests) |
| |
| onosaaaRxDroppedResponses.Set(kpi.RxDroppedResponses) |
| |
| onosaaaRxMalformedResponses.Set(kpi.RxMalformedResponses) |
| |
| onosaaaRxUnknownserver.Set(kpi.RxUnknownserver) |
| |
| onosaaaRequestRttMillis.Set(kpi.RequestRttMillis) |
| |
| onosaaaRequestReTx.Set(kpi.RequestReTx) |
| |
| onosaaaRxEapolLogoff.Set(kpi.RxEapolLogoff) |
| |
| onosaaaTxEapolResIdentityMsg.Set(kpi.TxEapolResIdentityMsg) |
| |
| onosaaaTxAuthSuccess.Set(kpi.TxAuthSuccess) |
| |
| onosaaaTxAuthFailure.Set(kpi.TxAuthFailure) |
| |
| onosaaaTxStartReq.Set(kpi.TxStartReq) |
| |
| onosaaaEapPktTxAuthChooseEap.Set(kpi.EapPktTxAuthChooseEap) |
| |
| onosaaaTxRespnotNak.Set(kpi.TxResponseNotNak) |
| } |
| |
| func exportOnosPppoeKPI(kpi OnosPppoeKPI) { |
| for _, s := range kpi.Subscribers { |
| |
| logger.WithFields(log.Fields{ |
| "Mac": s.Mac, |
| "Ip": s.Ip, |
| "SessionId": strconv.Itoa(s.SessionId), |
| "STag": strconv.Itoa(s.STag), |
| "CTag": strconv.Itoa(s.CTag), |
| "onuSerialNumber": s.SerialNumber, |
| }).Trace("Received OnosPppoeKPI message") |
| |
| onosPppoeUpTermBytes.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.UpTermBytes) |
| onosPppoeUpTermPackets.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.UpTermPackets) |
| onosPppoeUpDropBytes.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.UpDropBytes) |
| onosPppoeUpDropPackets.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.UpDropPackets) |
| onosPppoeUpControlPackets.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.UpControlPackets) |
| onosPppoeDownRxBytes.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.DownRxBytes) |
| onosPppoeDownRxPackets.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.DownRxPackets) |
| onosPppoeDownTxBytes.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.DownTxBytes) |
| onosPppoeDownTxPackets.WithLabelValues( |
| s.Mac, |
| s.Ip, |
| strconv.Itoa(s.SessionId), |
| strconv.Itoa(s.STag), |
| strconv.Itoa(s.CTag), |
| s.SerialNumber, |
| ).Set(s.DownTxPackets) |
| } |
| } |
| |
| func export(topic *string, data []byte) { |
| switch *topic { |
| case "voltha.kpis": |
| kpi := VolthaKPI{} |
| err := json.Unmarshal(data, &kpi) |
| if err != nil { |
| logger.Error("Invalid msg on voltha.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data)) |
| break |
| } |
| exportVolthaKPI(kpi) |
| case "onos.kpis": |
| kpi := OnosKPI{} |
| err := json.Unmarshal(data, &kpi) |
| if err != nil { |
| logger.Error("Invalid msg on onos.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data)) |
| break |
| } |
| exportOnosKPI(kpi) |
| case "importer.kpis": |
| kpi := ImporterKPI{} |
| strData := string(data) |
| idx := strings.Index(strData, "{") |
| strData = strData[idx:] |
| |
| var m map[string]interface{} |
| err := json.Unmarshal([]byte(strData), &m) |
| if err != nil { |
| logger.Error("Invalid msg on importer.kpis: %s", err.Error()) |
| logger.Debug("Unprocessed Msg: %s", strData) |
| break |
| } |
| if val, ok := m["TransceiverStatistics"]; ok { |
| stats := val.(map[string]interface{}) |
| //kpi.Timestamp = time.Now().UnixNano() |
| kpi.LaserBiasCurrent = stats["BiasCurrent"].(map[string]interface{})["Reading"].(float64) |
| kpi.Temperature = stats["Temperature"].(map[string]interface{})["Reading"].(float64) |
| kpi.TxPower = stats["TxPower"].(map[string]interface{})["Reading"].(float64) |
| kpi.Voltage = stats["Voltage"].(map[string]interface{})["Reading"].(float64) |
| } else { |
| logger.Error("Optical stats (TransceiverStatistics) information missing [topic=importer.kpis") |
| logger.Debug("Unprocessed Msg: %s", strData) |
| break |
| } |
| exportImporterKPI(kpi) |
| case "onos.aaa.stats.kpis": |
| kpi := OnosAaaKPI{} |
| err := json.Unmarshal(data, &kpi) |
| if err != nil { |
| logger.Error("Invalid msg on onos.aaa.stats.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data)) |
| break |
| } |
| exportOnosAaaKPI(kpi) |
| case "pppoe.stats": |
| kpi := OnosPppoeKPI{} |
| err := json.Unmarshal(data, &kpi) |
| if err != nil { |
| logger.Error("Invalid msg on pppoe.stats: %s, Unprocessed Msg: %s", err.Error(), string(data)) |
| break |
| } |
| exportOnosPppoeKPI(kpi) |
| default: |
| logger.Warn("Unexpected export. Topic [%s] not supported. Should not come here", *topic) |
| } |
| } |