func NewNetCollectorOrDie()

in pkg/systemstatsmonitor/net_collector.go [47:229]
165 lines of code
17 McCabe index (conditional complexity)

func NewNetCollectorOrDie(netConfig *ssmtypes.NetStatsConfig) *netCollector {
	nc := netCollector{config: netConfig}

	var err error

	nc.mNetDevRxBytes, err = metrics.NewInt64Metric(
		metrics.NetDevRxBytes,
		netConfig.MetricsConfigs[string(metrics.NetDevRxBytes)].DisplayName,
		"Cumulative count of bytes received.",
		"Byte",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxBytes, err)
	}

	nc.mNetDevRxPackets, err = metrics.NewInt64Metric(
		metrics.NetDevRxPackets,
		netConfig.MetricsConfigs[string(metrics.NetDevRxPackets)].DisplayName,
		"Cumulative count of packets received.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxPackets, err)
	}

	nc.mNetDevRxErrors, err = metrics.NewInt64Metric(
		metrics.NetDevRxErrors,
		netConfig.MetricsConfigs[string(metrics.NetDevRxErrors)].DisplayName,
		"Cumulative count of receive errors encountered.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxErrors, err)
	}

	nc.mNetDevRxDropped, err = metrics.NewInt64Metric(
		metrics.NetDevRxDropped,
		netConfig.MetricsConfigs[string(metrics.NetDevRxDropped)].DisplayName,
		"Cumulative count of packets dropped while receiving.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxDropped, err)
	}

	nc.mNetDevRxFifo, err = metrics.NewInt64Metric(
		metrics.NetDevRxFifo,
		netConfig.MetricsConfigs[string(metrics.NetDevRxFifo)].DisplayName,
		"Cumulative count of FIFO buffer errors.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxFifo, err)
	}

	nc.mNetDevRxFrame, err = metrics.NewInt64Metric(
		metrics.NetDevRxFrame,
		netConfig.MetricsConfigs[string(metrics.NetDevRxFrame)].DisplayName,
		"Cumulative count of packet framing errors.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxFrame, err)
	}

	nc.mNetDevRxCompressed, err = metrics.NewInt64Metric(
		metrics.NetDevRxCompressed,
		netConfig.MetricsConfigs[string(metrics.NetDevRxCompressed)].DisplayName,
		"Cumulative count of compressed packets received by the device driver.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxCompressed, err)
	}

	nc.mNetDevRxMulticast, err = metrics.NewInt64Metric(
		metrics.NetDevRxMulticast,
		netConfig.MetricsConfigs[string(metrics.NetDevRxMulticast)].DisplayName,
		"Cumulative count of multicast frames received by the device driver.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevRxMulticast, err)
	}

	nc.mNetDevTxBytes, err = metrics.NewInt64Metric(
		metrics.NetDevTxBytes,
		netConfig.MetricsConfigs[string(metrics.NetDevTxBytes)].DisplayName,
		"Cumulative count of bytes transmitted.",
		"Byte",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxBytes, err)
	}

	nc.mNetDevTxPackets, err = metrics.NewInt64Metric(
		metrics.NetDevTxPackets,
		netConfig.MetricsConfigs[string(metrics.NetDevTxPackets)].DisplayName,
		"Cumulative count of packets transmitted.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxPackets, err)
	}

	nc.mNetDevTxErrors, err = metrics.NewInt64Metric(
		metrics.NetDevTxErrors,
		netConfig.MetricsConfigs[string(metrics.NetDevTxErrors)].DisplayName,
		"Cumulative count of transmit errors encountered.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxErrors, err)
	}

	nc.mNetDevTxDropped, err = metrics.NewInt64Metric(
		metrics.NetDevTxDropped,
		netConfig.MetricsConfigs[string(metrics.NetDevTxDropped)].DisplayName,
		"Cumulative count of packets dropped while transmitting.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxDropped, err)
	}

	nc.mNetDevTxFifo, err = metrics.NewInt64Metric(
		metrics.NetDevTxFifo,
		netConfig.MetricsConfigs[string(metrics.NetDevTxFifo)].DisplayName,
		"Cumulative count of FIFO buffer errors.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxFifo, err)
	}

	nc.mNetDevTxCollisions, err = metrics.NewInt64Metric(
		metrics.NetDevTxCollisions,
		netConfig.MetricsConfigs[string(metrics.NetDevTxCollisions)].DisplayName,
		"Cumulative count of collisions detected on the interface.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxCollisions, err)
	}

	nc.mNetDevTxCarrier, err = metrics.NewInt64Metric(
		metrics.NetDevTxCarrier,
		netConfig.MetricsConfigs[string(metrics.NetDevTxCarrier)].DisplayName,
		"Cumulative count of carrier losses detected by the device driver.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxCarrier, err)
	}

	nc.mNetDevTxCompressed, err = metrics.NewInt64Metric(
		metrics.NetDevTxCompressed,
		netConfig.MetricsConfigs[string(metrics.NetDevTxCompressed)].DisplayName,
		"Cumulative count of compressed packets transmitted by the device driver.",
		"1",
		metrics.Sum,
		[]string{interfaceNameLabel})
	if err != nil {
		glog.Fatalf("Error initializing metric for %q: %v", metrics.NetDevTxCompressed, err)
	}

	return &nc
}