mirror of
				https://github.com/ClusterCockpit/cc-metric-collector.git
				synced 2025-10-26 14:45:06 +01:00 
			
		
		
		
	Define const values for net/dev fields
This commit is contained in:
		| @@ -13,7 +13,7 @@ import ( | |||||||
| 	lp "github.com/ClusterCockpit/cc-metric-collector/internal/ccMetric" | 	lp "github.com/ClusterCockpit/cc-metric-collector/internal/ccMetric" | ||||||
| ) | ) | ||||||
|  |  | ||||||
| const NETSTATFILE = `/proc/net/dev` | const NETSTATFILE = "/proc/net/dev" | ||||||
|  |  | ||||||
| type NetstatCollectorConfig struct { | type NetstatCollectorConfig struct { | ||||||
| 	IncludeDevices     []string `json:"include_devices"` | 	IncludeDevices     []string `json:"include_devices"` | ||||||
| @@ -38,14 +38,39 @@ func (m *NetstatCollector) Init(config json.RawMessage) error { | |||||||
| 	m.name = "NetstatCollector" | 	m.name = "NetstatCollector" | ||||||
| 	m.setup() | 	m.setup() | ||||||
| 	m.lastTimestamp = time.Now() | 	m.lastTimestamp = time.Now() | ||||||
| 	m.meta = map[string]string{"source": m.name, "group": "Network"} | 	m.meta = map[string]string{ | ||||||
| 	m.devtags = make(map[string]map[string]string) | 		"source": m.name, | ||||||
| 	nameIndexMap := map[string]int{ | 		"group":  "Network", | ||||||
| 		"net_bytes_in":  1, |  | ||||||
| 		"net_pkts_in":   2, |  | ||||||
| 		"net_bytes_out": 9, |  | ||||||
| 		"net_pkts_out":  10, |  | ||||||
| 	} | 	} | ||||||
|  | 	m.devtags = make(map[string]map[string]string) | ||||||
|  |  | ||||||
|  | 	const ( | ||||||
|  | 		fieldInterface          = iota | ||||||
|  | 		fieldReceiveBytes       = iota | ||||||
|  | 		fieldReceivePackets     = iota | ||||||
|  | 		fieldReceiveErrs        = iota | ||||||
|  | 		fieldReceiveDrop        = iota | ||||||
|  | 		fieldReceiveFifo        = iota | ||||||
|  | 		fieldReceiveFrame       = iota | ||||||
|  | 		fieldReceiveCompressed  = iota | ||||||
|  | 		fieldReceiveMulticast   = iota | ||||||
|  | 		fieldTransmitBytes      = iota | ||||||
|  | 		fieldTransmitPackets    = iota | ||||||
|  | 		fieldTransmitErrs       = iota | ||||||
|  | 		fieldTransmitDrop       = iota | ||||||
|  | 		fieldTransmitFifo       = iota | ||||||
|  | 		fieldTransmitColls      = iota | ||||||
|  | 		fieldTransmitCarrier    = iota | ||||||
|  | 		fieldTransmitCompressed = iota | ||||||
|  | 	) | ||||||
|  |  | ||||||
|  | 	nameIndexMap := map[string]int{ | ||||||
|  | 		"net_bytes_in":  fieldReceiveBytes, | ||||||
|  | 		"net_pkts_in":   fieldReceivePackets, | ||||||
|  | 		"net_bytes_out": fieldTransmitBytes, | ||||||
|  | 		"net_pkts_out":  fieldTransmitPackets, | ||||||
|  | 	} | ||||||
|  |  | ||||||
| 	m.matches = make(map[string]map[string]NetstatCollectorMetric) | 	m.matches = make(map[string]map[string]NetstatCollectorMetric) | ||||||
| 	if len(config) > 0 { | 	if len(config) > 0 { | ||||||
| 		err := json.Unmarshal(config, &m.config) | 		err := json.Unmarshal(config, &m.config) | ||||||
| @@ -54,7 +79,7 @@ func (m *NetstatCollector) Init(config json.RawMessage) error { | |||||||
| 			return err | 			return err | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
| 	file, err := os.Open(string(NETSTATFILE)) | 	file, err := os.Open(NETSTATFILE) | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		cclog.ComponentError(m.name, err.Error()) | 		cclog.ComponentError(m.name, err.Error()) | ||||||
| 		return err | 		return err | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user