owncast/metrics/hardware.go

package metrics

import (
	"time"

	"github.com/shirou/gopsutil/v4/cpu"
	"github.com/shirou/gopsutil/v4/disk"
	"github.com/shirou/gopsutil/v4/mem"

	log "github.com/sirupsen/logrus"
)

// Max number of metrics we want to keep.
const maxCollectionValues = 300

func collectCPUUtilization() {
	if len(metrics.CPUUtilizations) > maxCollectionValues {
		metrics.CPUUtilizations = metrics.CPUUtilizations[1:]
	}

	v, err := cpu.Percent(0, false)
	if err != nil {
		log.Errorln(err)
		return
	}

	// Default to zero but try to use the cumulative values of all the CPUs
	// if values exist.
	value := 0.0
	if len(v) > 0 {
		value = v[0]
	}

	metricValue := TimestampedValue{time.Now(), value}
	metrics.CPUUtilizations = append(metrics.CPUUtilizations, metricValue)
	cpuUsage.Set(metricValue.Value)
}

func collectRAMUtilization() {
	if len(metrics.RAMUtilizations) > maxCollectionValues {
		metrics.RAMUtilizations = metrics.RAMUtilizations[1:]
	}

	memoryUsage, _ := mem.VirtualMemory()
	metricValue := TimestampedValue{time.Now(), memoryUsage.UsedPercent}
	metrics.RAMUtilizations = append(metrics.RAMUtilizations, metricValue)
}

func collectDiskUtilization() {
	path := "./"
	diskUse, _ := disk.Usage(path)

	if len(metrics.DiskUtilizations) > maxCollectionValues {
		metrics.DiskUtilizations = metrics.DiskUtilizations[1:]
	}

	metricValue := TimestampedValue{time.Now(), diskUse.UsedPercent}
	metrics.DiskUtilizations = append(metrics.DiskUtilizations, metricValue)
}