yanic/webserver/prometheus.go

package webserver

import (
	"fmt"
	"strconv"

	"github.com/FreifunkBremen/yanic/data"
	"github.com/FreifunkBremen/yanic/runtime"

	"github.com/prometheus/client_golang/prometheus"
)

var (
	promDescNodeInfo = prometheus.NewDesc("yanic_node_info", "node info on labels", []string{
		"node_id",
		"hostname",
		"owner",
		"latitude",
		"longitude",
		"site_code",
		"domain_code",
		"model",
		"nproc",
		"firmware_base",
		"firmware_release",
		"autoupdater",
	}, prometheus.Labels{})

	nodeLabels = []string{"node_id"}

	promDescNodeUP        = prometheus.NewDesc("yanic_node_up", "node is up", nodeLabels, prometheus.Labels{})
	promDescNodeFirstseen = prometheus.NewDesc("yanic_node_firstseen", "node firstseen as timestemp", nodeLabels, prometheus.Labels{})
	promDescNodeLastseen  = prometheus.NewDesc("yanic_node_lastseen", "node lastseen as timestemp", nodeLabels, prometheus.Labels{})

	promDescNodeLoad = prometheus.NewDesc("yanic_node_load", "load of node", nodeLabels, prometheus.Labels{})

	promDescNodeTimeUP   = prometheus.NewDesc("yanic_node_time_up", "", nodeLabels, prometheus.Labels{})
	promDescNodeTimeIdle = prometheus.NewDesc("yanic_node_time_idle", "", nodeLabels, prometheus.Labels{})

	promDescNodeProcRunning = prometheus.NewDesc("yanic_node_proc_running", "", nodeLabels, prometheus.Labels{})

	// Clients - complete
	promDescNodeClientsWifi   = prometheus.NewDesc("yanic_node_clients_wifi", "", nodeLabels, prometheus.Labels{})
	promDescNodeClientsWifi24 = prometheus.NewDesc("yanic_node_clients_wifi24", "", nodeLabels, prometheus.Labels{})
	promDescNodeClientsWifi5  = prometheus.NewDesc("yanic_node_clients_wifi5", "", nodeLabels, prometheus.Labels{})

	promDescNodeClientsOwe   = prometheus.NewDesc("yanic_node_clients_owe", "", nodeLabels, prometheus.Labels{})
	promDescNodeClientsOwe24 = prometheus.NewDesc("yanic_node_clients_owe24", "", nodeLabels, prometheus.Labels{})
	promDescNodeClientsOwe5  = prometheus.NewDesc("yanic_node_clients_owe5", "", nodeLabels, prometheus.Labels{})
	promDescNodeClientsTotal = prometheus.NewDesc("yanic_node_clients_total", "", nodeLabels, prometheus.Labels{})

	// Memory - compelte
	promDescNodeMemBuffers   = prometheus.NewDesc("yanic_node_memmory_buffers", "", nodeLabels, prometheus.Labels{})
	promDescNodeMemCached    = prometheus.NewDesc("yanic_node_memmory_cached", "", nodeLabels, prometheus.Labels{})
	promDescNodeMemFree      = prometheus.NewDesc("yanic_node_memmory_free", "", nodeLabels, prometheus.Labels{})
	promDescNodeMemTotal     = prometheus.NewDesc("yanic_node_memmory_total", "", nodeLabels, prometheus.Labels{})
	promDescNodeMemAvailable = prometheus.NewDesc("yanic_node_memmory_available", "", nodeLabels, prometheus.Labels{})

	// ProcStats - complete
	promDescNodeStatCPUUser    = prometheus.NewDesc("yanic_node_stat_cpu_user", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatCPUNice    = prometheus.NewDesc("yanic_node_stat_cpu_nice", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatCPUSystem  = prometheus.NewDesc("yanic_node_stat_cpu_system", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatCPUIdle    = prometheus.NewDesc("yanic_node_stat_cpu_idle", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatCPUIOWait  = prometheus.NewDesc("yanic_node_stat_cpu_iowait", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatCPUIRQ     = prometheus.NewDesc("yanic_node_stat_cpu_irq", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatCPUSoftIRQ = prometheus.NewDesc("yanic_node_stat_cpu_softirq", "", nodeLabels, prometheus.Labels{})

	promDescNodeStatIntr            = prometheus.NewDesc("yanic_node_stat_intr", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatContextSwitches = prometheus.NewDesc("yanic_node_stat_ctxt", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatSoftIRQ         = prometheus.NewDesc("yanic_node_stat_softirq", "", nodeLabels, prometheus.Labels{})
	promDescNodeStatProcesses       = prometheus.NewDesc("yanic_node_stat_processes", "", nodeLabels, prometheus.Labels{})

	// Traffic - complete
	promDescNodeTrafficRxBytes   = prometheus.NewDesc("yanic_node_traffic_rx_bytes", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficRxPackets = prometheus.NewDesc("yanic_node_traffic_rx_packets", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficRxDropped = prometheus.NewDesc("yanic_node_traffic_rx_dropped", "", nodeLabels, prometheus.Labels{})

	promDescNodeTrafficTxBytes   = prometheus.NewDesc("yanic_node_traffic_tx_bytes", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficTxPackets = prometheus.NewDesc("yanic_node_traffic_tx_packets", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficTxDropped = prometheus.NewDesc("yanic_node_traffic_tx_dropped", "", nodeLabels, prometheus.Labels{})

	promDescNodeTrafficForwardBytes   = prometheus.NewDesc("yanic_node_traffic_forward_bytes", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficForwardPackets = prometheus.NewDesc("yanic_node_traffic_forward_packets", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficForwardDropped = prometheus.NewDesc("yanic_node_traffic_forward_dropped", "", nodeLabels, prometheus.Labels{})

	promDescNodeTrafficMgmtRxBytes   = prometheus.NewDesc("yanic_node_traffic_mgmt_rx_bytes", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficMgmtRxPackets = prometheus.NewDesc("yanic_node_traffic_mgmt_rx_packets", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficMgmtRxDropped = prometheus.NewDesc("yanic_node_traffic_mgmt_rx_dropped", "", nodeLabels, prometheus.Labels{})

	promDescNodeTrafficMgmtTxBytes   = prometheus.NewDesc("yanic_node_traffic_mgmt_tx_bytes", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficMgmtTxPackets = prometheus.NewDesc("yanic_node_traffic_mgmt_tx_packets", "", nodeLabels, prometheus.Labels{})
	promDescNodeTrafficMgmtTxDropped = prometheus.NewDesc("yanic_node_traffic_mgmt_tx_dropped", "", nodeLabels, prometheus.Labels{})

	// Wireless - just necessary
	allLabelsWithFrequency      = append(nodeLabels, "frequency", "frequency_name")
	promDescNodeFrequency       = prometheus.NewDesc("yanic_node_frequency", "", allLabelsWithFrequency, prometheus.Labels{})
	promDescNodeAirtimeChanUtil = prometheus.NewDesc("yanic_node_airtime_chan_util", "", allLabelsWithFrequency, prometheus.Labels{})
	promDescNodeAirtimeTxUtil   = prometheus.NewDesc("yanic_node_airtime_tx_util", "", allLabelsWithFrequency, prometheus.Labels{})
	promDescNodeAirtimeRxUtil   = prometheus.NewDesc("yanic_node_airtime_rx_util", "", allLabelsWithFrequency, prometheus.Labels{})
	promDescNodeAirtimeNoise    = prometheus.NewDesc("yanic_node_airtime_noise", "", allLabelsWithFrequency, prometheus.Labels{})
	promDescNodeWirelessTxPower = prometheus.NewDesc("yanic_node_wireless_txpower", "", allLabelsWithFrequency, prometheus.Labels{})

	// Links - just necessary
	labelLinks     = []string{"source_id", "target_id", "source_address", "target_address", "type"}
	promDescLinkTQ = prometheus.NewDesc("yanic_link_tq", "", labelLinks, prometheus.Labels{})
)

type Prometheus struct {
	Enable        bool     `toml:"enable"`
	DisableLabels []string `toml:"disable_labels"`
	nodes         *runtime.Nodes
	disLabels     map[string]bool
}

func (prom *Prometheus) Init(nodes *runtime.Nodes) {
	prom.nodes = nodes
	prom.disLabels = make(map[string]bool)
	for _, label := range prom.DisableLabels {
		prom.disLabels[label] = false
	}

}

func (prom *Prometheus) Describe(d chan<- *prometheus.Desc) {
	d <- promDescNodeInfo

	d <- promDescNodeUP
	d <- promDescNodeFirstseen
	d <- promDescNodeLastseen

	d <- promDescNodeLoad

	d <- promDescNodeTimeUP
	d <- promDescNodeTimeIdle

	d <- promDescNodeProcRunning

	d <- promDescNodeClientsWifi
	d <- promDescNodeClientsWifi24
	d <- promDescNodeClientsWifi5

	d <- promDescNodeClientsOwe
	d <- promDescNodeClientsOwe24
	d <- promDescNodeClientsOwe5
	d <- promDescNodeClientsTotal

	d <- promDescNodeMemBuffers
	d <- promDescNodeMemCached
	d <- promDescNodeMemFree
	d <- promDescNodeMemTotal
	d <- promDescNodeMemAvailable

	d <- promDescNodeStatCPUUser
	d <- promDescNodeStatCPUNice
	d <- promDescNodeStatCPUSystem
	d <- promDescNodeStatCPUIdle
	d <- promDescNodeStatCPUIOWait
	d <- promDescNodeStatCPUIRQ
	d <- promDescNodeStatCPUSoftIRQ

	d <- promDescNodeStatIntr
	d <- promDescNodeStatContextSwitches
	d <- promDescNodeStatSoftIRQ
	d <- promDescNodeStatProcesses

	d <- promDescNodeTrafficRxBytes
	d <- promDescNodeTrafficRxPackets
	d <- promDescNodeTrafficRxDropped

	d <- promDescNodeTrafficTxBytes
	d <- promDescNodeTrafficTxPackets
	d <- promDescNodeTrafficTxDropped

	d <- promDescNodeTrafficForwardBytes
	d <- promDescNodeTrafficForwardPackets
	d <- promDescNodeTrafficForwardDropped

	d <- promDescNodeTrafficMgmtRxBytes
	d <- promDescNodeTrafficMgmtRxPackets
	d <- promDescNodeTrafficMgmtRxDropped

	d <- promDescNodeTrafficMgmtTxBytes
	d <- promDescNodeTrafficMgmtTxPackets
	d <- promDescNodeTrafficMgmtTxDropped

	d <- promDescNodeFrequency
	d <- promDescNodeAirtimeChanUtil
	d <- promDescNodeAirtimeRxUtil
	d <- promDescNodeAirtimeTxUtil
	d <- promDescNodeAirtimeNoise
	d <- promDescNodeWirelessTxPower

	d <- promDescLinkTQ
}

func (prom *Prometheus) getNodeLabels(ni *data.Nodeinfo) []string {
	labels := make([]string, 12)
	labels[0] = ni.NodeID
	if _, nok := prom.disLabels["hostname"]; !nok {
		labels[1] = ni.Hostname
	} else {
		labels[1] = "DISABLED"
	}
	if _, nok := prom.disLabels["owner"]; !nok {
		if owner := ni.Owner; owner != nil {
			labels[2] = owner.Contact
		}
	} else {
		labels[2] = "DISABLED"
	}
	if _, nok := prom.disLabels["location"]; !nok {
		if location := ni.Location; location != nil {
			labels[3] = fmt.Sprintf("%v", location.Latitude)
			labels[4] = fmt.Sprintf("%v", location.Longitude)
		}
	} else {
		labels[3] = "DISABLED"
		labels[4] = "DISABLED"
	}
	labels[5] = ni.System.SiteCode
	labels[6] = ni.System.DomainCode
	labels[7] = ni.Hardware.Model
	labels[8] = strconv.Itoa(ni.Hardware.Nproc)
	if firmware := ni.Software.Firmware; firmware != nil {
		labels[9] = firmware.Base
		labels[10] = firmware.Release
	}
	if ni.Software.Autoupdater != nil && ni.Software.Autoupdater.Enabled {
		labels[11] = ni.Software.Autoupdater.Branch
	} else {
		labels[11] = runtime.DISABLED_AUTOUPDATER
	}
	return labels

}

func (prom *Prometheus) Collect(metrics chan<- prometheus.Metric) {
	prom.nodes.Lock()
	defer prom.nodes.Unlock()
	for _, node := range prom.nodes.List {
		nodeinfo := node.Nodeinfo
		if nodeinfo == nil {
			continue
		}
		nodeLabelValues := prom.getNodeLabels(nodeinfo)
		if m, err := prometheus.NewConstMetric(
			promDescNodeInfo,
			prometheus.CounterValue,
			1,
			nodeLabelValues...); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeFirstseen,
			prometheus.CounterValue,
			float64(node.Firstseen.Unix()),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeLastseen,
			prometheus.CounterValue,
			float64(node.Lastseen.Unix()),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if !node.Online {
			if m, err := prometheus.NewConstMetric(
				promDescNodeUP,
				prometheus.GaugeValue,
				0,
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			continue
		}
		stats := node.Statistics
		if stats == nil {
			continue
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeUP,
			prometheus.GaugeValue,
			1,
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}

		if m, err := prometheus.NewConstMetric(
			promDescNodeLoad,
			prometheus.GaugeValue,
			stats.LoadAverage,
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}

		if m, err := prometheus.NewConstMetric(
			promDescNodeTimeUP,
			prometheus.GaugeValue,
			float64(stats.Uptime),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}

		if m, err := prometheus.NewConstMetric(
			promDescNodeTimeIdle,
			prometheus.GaugeValue,
			stats.Idletime,
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}

		if m, err := prometheus.NewConstMetric(
			promDescNodeProcRunning,
			prometheus.GaugeValue,
			float64(stats.Processes.Running),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}

		// Clients
		if m, err := prometheus.NewConstMetric(
			promDescNodeClientsWifi,
			prometheus.GaugeValue,
			float64(stats.Clients.Wifi),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeClientsWifi24,
			prometheus.GaugeValue,
			float64(stats.Clients.Wifi24),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeClientsWifi5,
			prometheus.GaugeValue,
			float64(stats.Clients.Wifi5),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeClientsOwe,
			prometheus.GaugeValue,
			float64(stats.Clients.OWE),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeClientsOwe24,
			prometheus.GaugeValue,
			float64(stats.Clients.OWE24),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeClientsOwe5,
			prometheus.GaugeValue,
			float64(stats.Clients.OWE5),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeClientsTotal,
			prometheus.GaugeValue,
			float64(stats.Clients.Total),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}

		// Memory
		if m, err := prometheus.NewConstMetric(
			promDescNodeMemBuffers,
			prometheus.GaugeValue,
			float64(stats.Memory.Buffers),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeMemCached,
			prometheus.GaugeValue,
			float64(stats.Memory.Cached),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeMemFree,
			prometheus.GaugeValue,
			float64(stats.Memory.Free),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeMemTotal,
			prometheus.GaugeValue,
			float64(stats.Memory.Total),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}
		if m, err := prometheus.NewConstMetric(
			promDescNodeMemAvailable,
			prometheus.GaugeValue,
			float64(stats.Memory.Available),
			nodeinfo.NodeID); err == nil {
			metrics <- m
		}

		if procstat := stats.ProcStats; procstat != nil {
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatCPUUser,
				prometheus.GaugeValue,
				float64(procstat.CPU.User),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatCPUNice,
				prometheus.GaugeValue,
				float64(procstat.CPU.Nice),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatCPUSystem,
				prometheus.GaugeValue,
				float64(procstat.CPU.System),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatCPUIdle,
				prometheus.GaugeValue,
				float64(procstat.CPU.Idle),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatCPUIOWait,
				prometheus.GaugeValue,
				float64(procstat.CPU.IOWait),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatCPUIRQ,
				prometheus.GaugeValue,
				float64(procstat.CPU.IRQ),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatCPUSoftIRQ,
				prometheus.GaugeValue,
				float64(procstat.CPU.SoftIRQ),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}

			if m, err := prometheus.NewConstMetric(
				promDescNodeStatIntr,
				prometheus.GaugeValue,
				float64(procstat.Intr),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatContextSwitches,
				prometheus.GaugeValue,
				float64(procstat.ContextSwitches),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatSoftIRQ,
				prometheus.GaugeValue,
				float64(procstat.SoftIRQ),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeStatProcesses,
				prometheus.GaugeValue,
				float64(procstat.Processes),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
		}
		if t := stats.Traffic.Rx; t != nil {
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficRxBytes,
				prometheus.GaugeValue,
				float64(t.Bytes),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficRxPackets,
				prometheus.GaugeValue,
				float64(t.Packets),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficRxDropped,
				prometheus.GaugeValue,
				float64(t.Dropped),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
		}
		if t := stats.Traffic.Tx; t != nil {
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficTxBytes,
				prometheus.GaugeValue,
				float64(t.Bytes),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficTxPackets,
				prometheus.GaugeValue,
				float64(t.Packets),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficTxDropped,
				prometheus.GaugeValue,
				float64(t.Dropped),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
		}
		if t := stats.Traffic.Forward; t != nil {
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficForwardBytes,
				prometheus.GaugeValue,
				float64(t.Bytes),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficForwardPackets,
				prometheus.GaugeValue,
				float64(t.Packets),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficForwardDropped,
				prometheus.GaugeValue,
				float64(t.Dropped),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
		}
		if t := stats.Traffic.MgmtTx; t != nil {
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficMgmtTxBytes,
				prometheus.GaugeValue,
				float64(t.Bytes),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficMgmtTxPackets,
				prometheus.GaugeValue,
				float64(t.Packets),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficMgmtTxDropped,
				prometheus.GaugeValue,
				float64(t.Dropped),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
		}
		if t := stats.Traffic.MgmtRx; t != nil {
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficMgmtRxBytes,
				prometheus.GaugeValue,
				float64(t.Bytes),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficMgmtRxPackets,
				prometheus.GaugeValue,
				float64(t.Packets),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeTrafficMgmtRxDropped,
				prometheus.GaugeValue,
				float64(t.Dropped),
				nodeinfo.NodeID); err == nil {
				metrics <- m
			}
		}

		// add a label for frequency_name
		labelIndex := len(nodeLabels)
		labels := []string{nodeinfo.NodeID, "", ""}
		for _, airtime := range stats.Wireless {
			labels[labelIndex] = strconv.Itoa(int(airtime.Frequency))
			labels[labelIndex+1] = airtime.FrequencyName()

			if m, err := prometheus.NewConstMetric(
				promDescNodeFrequency,
				prometheus.GaugeValue,
				float64(airtime.Frequency),
				labels...); err == nil {
				metrics <- m
			}

			if m, err := prometheus.NewConstMetric(
				promDescNodeAirtimeChanUtil,
				prometheus.GaugeValue,
				float64(airtime.ChanUtil),
				labels...); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeAirtimeTxUtil,
				prometheus.GaugeValue,
				float64(airtime.TxUtil),
				labels...); err == nil {
				metrics <- m
			}

			if m, err := prometheus.NewConstMetric(
				promDescNodeAirtimeRxUtil,
				prometheus.GaugeValue,
				float64(airtime.RxUtil),
				labels...); err == nil {
				metrics <- m
			}
			if m, err := prometheus.NewConstMetric(
				promDescNodeAirtimeNoise,
				prometheus.GaugeValue,
				float64(airtime.Noise),
				labels...); err == nil {
				metrics <- m
			}
			if wireless := nodeinfo.Wireless; wireless != nil {
				if airtime.Frequency < 5000 {
					if m, err := prometheus.NewConstMetric(
						promDescNodeWirelessTxPower,
						prometheus.GaugeValue,
						float64(wireless.TxPower24),
						labels...); err == nil {
						metrics <- m
					}
				} else {
					if m, err := prometheus.NewConstMetric(
						promDescNodeWirelessTxPower,
						prometheus.GaugeValue,
						float64(wireless.TxPower5),
						labels...); err == nil {
						metrics <- m
					}
				}
			}
		}
		for _, link := range prom.nodes.NodeLinks(node) {
			if m, err := prometheus.NewConstMetric(
				promDescLinkTQ,
				prometheus.GaugeValue,
				float64(link.TQ),
				// labels:
				link.SourceID,
				link.TargetID,
				link.SourceAddress,
				link.TargetAddress,
				link.Type.String(),
			); err == nil {
				metrics <- m
			}
		}
	}
}