| // 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" |
| ) |
| |
| 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"}, |
| ) |
| ) |
| |
| 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) { |
| // TODO: add metrics for importer data |
| logger.Info("To be implemented") |
| } |
| |
| 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) |
| } |
| |
| 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{} |
| err := json.Unmarshal(data, &kpi) |
| if err != nil { |
| logger.Error("Invalid msg on importer.kpis: %s, Unprocessed Msg: %s", err.Error(), string(data)) |
| 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) |
| } |
| } |