jalr/vodafone-station-exporter
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add OFDMA upstream channel information

Browse source
This commit is contained in:
Gerrit M. Keller 2021-12-06 11:50:23 +00:00 • committed by Ruben Jenster
parent cd1acd3804
commit 0d17408255
2 changed files with 45 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

14
collector/api.go
View file

@ -58,6 +58,7 @@ type DocsisStatusResponse struct {
type DocsisStatusData struct { type DocsisStatusData struct {
OfdmDownstreamData []*OfdmDownstreamData `json:"ofdm_downstream"` OfdmDownstreamData []*OfdmDownstreamData `json:"ofdm_downstream"`
Downstream []*DocsisDownstreamChannel `json:"downstream"` Downstream []*DocsisDownstreamChannel `json:"downstream"`
OfdmaUpstreamData []*OfdmaUpstreamData `json:"ofdma_upstream"`
Upstream []*DocsisUpstreamChannel `json:"upstream"` Upstream []*DocsisUpstreamChannel `json:"upstream"`
} }
@ -86,6 +87,19 @@ type DocsisDownstreamChannel struct {
ChannelType string `json:"ChannelType"` ChannelType string `json:"ChannelType"`
} }
type OfdmaUpstreamData struct {
Id string `json:"__id"`
ChannelIdUp string `json:"channelidup"`
StartFrequency string `json:"start_frequency"`
EndFrequency string `json:"end_frequency"`
Power string `json:"power"`
CentralFrequency string `json:"CentralFrequency"`
Bandwidth string `json:"bandwidth"`
Fft string `json:"FFT"`
ChannelType string `json:"ChannelType"`
RangingStatus string `json:"RangingStatus"`
}
type DocsisUpstreamChannel struct { type DocsisUpstreamChannel struct {
Id string `json:"__id"` Id string `json:"__id"`
ChannelIdUp string `json:"channelidup"` ChannelIdUp string `json:"channelidup"`

31
collector/collector.go
View file

@ -37,6 +37,13 @@ var (
powerUpstreamDesc *prometheus.Desc powerUpstreamDesc *prometheus.Desc
rangingStatusUpstreamDesc *prometheus.Desc rangingStatusUpstreamDesc *prometheus.Desc
startFrequencyOfdmaUpstreamDesc *prometheus.Desc
endFrequencyOfdmaUpstreamDesc *prometheus.Desc
centralFrequencyOfdmaUpstreamDesc *prometheus.Desc
bandwidthOfdmaUpstreamDesc *prometheus.Desc
powerOfdmaUpstreamDesc *prometheus.Desc
rangingStatusOfdmaUpstreamDesc *prometheus.Desc
firewallStatusDesc *prometheus.Desc firewallStatusDesc *prometheus.Desc
lanIPv4Desc *prometheus.Desc lanIPv4Desc *prometheus.Desc
lanModeDesc *prometheus.Desc lanModeDesc *prometheus.Desc
@ -115,6 +122,14 @@ func init() {
powerUpstreamDesc = prometheus.NewDesc(prefix+"upstream_power_dBmV", "Power", upstreamLabels, nil) powerUpstreamDesc = prometheus.NewDesc(prefix+"upstream_power_dBmV", "Power", upstreamLabels, nil)
rangingStatusUpstreamDesc = prometheus.NewDesc(prefix+"upstream_ranging_status_info", "Ranging status", append(upstreamLabels, "status"), nil) rangingStatusUpstreamDesc = prometheus.NewDesc(prefix+"upstream_ranging_status_info", "Ranging status", append(upstreamLabels, "status"), nil)
ofdmaUpstreamLabels := []string{"id", "channel_id_up", "fft", "channel_type"}
startFrequencyOfdmaUpstreamDesc = prometheus.NewDesc(prefix+"ofdma_upstream_start_frequency_hertz", "Start frequency", ofdmaUpstreamLabels, nil)
endFrequencyOfdmaUpstreamDesc = prometheus.NewDesc(prefix+"ofdma_upstream_end_frequency_hertz", "End frequency", ofdmaUpstreamLabels, nil)
centralFrequencyOfdmaUpstreamDesc = prometheus.NewDesc(prefix+"ofdma_upstream_central_frequency_hertz", "Central frequency", ofdmaUpstreamLabels, nil)
bandwidthOfdmaUpstreamDesc = prometheus.NewDesc(prefix+"ofdma_upstream_bandwidth_hertz", "Bandwidth", ofdmaUpstreamLabels, nil)
powerOfdmaUpstreamDesc = prometheus.NewDesc(prefix+"ofdma_upstream_power_dBmV", "Power", ofdmaUpstreamLabels, nil)
rangingStatusOfdmaUpstreamDesc = prometheus.NewDesc(prefix+"ofdma_upstream_ranging_status_info", "Ranging status", append(ofdmaUpstreamLabels, "status"), nil)
firewallStatusDesc = prometheus.NewDesc(prefix+"firewall_status_info", "Firewall status", []string{"firewall_status"}, nil) firewallStatusDesc = prometheus.NewDesc(prefix+"firewall_status_info", "Firewall status", []string{"firewall_status"}, nil)
lanIPv4Desc = prometheus.NewDesc(prefix+"lan_ip4_info", "LAN IPv4 info", []string{"lan_ip4"}, nil) lanIPv4Desc = prometheus.NewDesc(prefix+"lan_ip4_info", "LAN IPv4 info", []string{"lan_ip4"}, nil)
lanModeDesc = prometheus.NewDesc(prefix+"lan_mode_info", "LAN mode info", []string{"mode"}, nil) lanModeDesc = prometheus.NewDesc(prefix+"lan_mode_info", "LAN mode info", []string{"mode"}, nil)
@ -189,6 +204,13 @@ func (c *Collector) Describe(ch chan<- *prometheus.Desc) {
ch <- powerUpstreamDesc ch <- powerUpstreamDesc
ch <- rangingStatusUpstreamDesc ch <- rangingStatusUpstreamDesc
ch <- startFrequencyOfdmaUpstreamDesc
ch <- endFrequencyOfdmaUpstreamDesc
ch <- centralFrequencyOfdmaUpstreamDesc
ch <- bandwidthOfdmaUpstreamDesc
ch <- powerOfdmaUpstreamDesc
ch <- rangingStatusOfdmaUpstreamDesc
ch <- firewallStatusDesc ch <- firewallStatusDesc
ch <- lanIPv4Desc ch <- lanIPv4Desc
ch <- lanModeDesc ch <- lanModeDesc
@ -282,6 +304,15 @@ func (c *Collector) Collect(ch chan<- prometheus.Metric) {
ch <- prometheus.MustNewConstMetric(powerUpstreamDesc, prometheus.GaugeValue, parse2float(upstreamChannel.Power), labels...) ch <- prometheus.MustNewConstMetric(powerUpstreamDesc, prometheus.GaugeValue, parse2float(upstreamChannel.Power), labels...)
ch <- prometheus.MustNewConstMetric(rangingStatusUpstreamDesc, prometheus.GaugeValue, 1, append(labels, upstreamChannel.RangingStatus)...) ch <- prometheus.MustNewConstMetric(rangingStatusUpstreamDesc, prometheus.GaugeValue, 1, append(labels, upstreamChannel.RangingStatus)...)
} }
for _, ofdmaUpstreamChannel := range docsisStatusResponse.Data.OfdmaUpstreamData {
labels := []string{ofdmaUpstreamChannel.Id, ofdmaUpstreamChannel.ChannelIdUp, ofdmaUpstreamChannel.Fft, ofdmaUpstreamChannel.ChannelType}
ch <- prometheus.MustNewConstMetric(startFrequencyOfdmaUpstreamDesc, prometheus.GaugeValue, parse2float(ofdmaUpstreamChannel.StartFrequency)*10e9, labels...)
ch <- prometheus.MustNewConstMetric(endFrequencyOfdmaUpstreamDesc, prometheus.GaugeValue, parse2float(ofdmaUpstreamChannel.EndFrequency)*10e9, labels...)
ch <- prometheus.MustNewConstMetric(centralFrequencyOfdmaUpstreamDesc, prometheus.GaugeValue, parse2float(ofdmaUpstreamChannel.CentralFrequency)*10e9, labels...)
ch <- prometheus.MustNewConstMetric(bandwidthOfdmaUpstreamDesc, prometheus.GaugeValue, parse2float(ofdmaUpstreamChannel.Bandwidth)*10e9, labels...)
ch <- prometheus.MustNewConstMetric(powerOfdmaUpstreamDesc, prometheus.GaugeValue, parse2float(ofdmaUpstreamChannel.Power)*10e9, labels...)
ch <- prometheus.MustNewConstMetric(rangingStatusOfdmaUpstreamDesc, prometheus.GaugeValue, 1, append(labels, ofdmaUpstreamChannel.RangingStatus)...)
}
} }
stationStatusResponse, err := c.Station.GetStationStatus() stationStatusResponse, err := c.Station.GetStationStatus()