helper

Documentation

Index

• func GetContainerMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (float64, error)
• func GetDeviceMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (float64, error)
• func GetDeviceMetricWithTime(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (metricutil.MetricData, error)
• func GetNodeMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (float64, error)
• func GetNodeMetricWithTime(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (metricutil.MetricData, error)
• func GetNumaMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (float64, error)
• func GetNumaMetricWithTime(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (metricutil.MetricData, error)
• func GetPodMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (float64, error)
• func GetVolumeMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, ...) (float64, error)
• func GetWatermarkMetrics(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, numaID int) (free, total, scaleFactor float64, err error)
• type ReclaimMetrics
  • func GetReclaimMetrics(cpus machine.CPUSet, cgroupPath string, metricsFetcher types.MetricsFetcher) (*ReclaimMetrics, error)

Functions

func GetContainerMetric

func GetContainerMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, podUID, containerName, metricName string, numaID int) (float64, error)

func GetDeviceMetric

func GetDeviceMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, metricName string, devName string) (float64, error)

func GetDeviceMetricWithTime

func GetDeviceMetricWithTime(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, metricName string, devName string) (metricutil.MetricData, error)

func GetNodeMetric

func GetNodeMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, metricName string) (float64, error)

func GetNodeMetricWithTime

func GetNodeMetricWithTime(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, metricName string) (metricutil.MetricData, error)

func GetNumaMetric

func GetNumaMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, metricName string, numaID int) (float64, error)

func GetNumaMetricWithTime

func GetNumaMetricWithTime(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, metricName string, numaID int) (metricutil.MetricData, error)

func GetPodMetric

func GetPodMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, pod *v1.Pod, metricName string, numaID int) (float64, error)

GetPodMetric returns the value of a pod-level metric. And the value of a pod-level metric is calculated by summing the metric values for all containers in that pod.

func GetVolumeMetric

func GetVolumeMetric(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, podUID, volumeName, metricName string) (float64, error)

func GetWatermarkMetrics

func GetWatermarkMetrics(metricsFetcher types.MetricsFetcher, emitter metrics.MetricEmitter, numaID int) (free, total, scaleFactor float64, err error)

GetWatermarkMetrics returns system-water mark related metrics (config) if numa node is specified, return config in this numa; otherwise return system-level config

Types

type ReclaimMetrics

type ReclaimMetrics struct {
	// total cpu usage of cpus in reclaim pool
	PoolCPUUsage float64
	// cpu usage of root cgroup for reclaim pods
	CgroupCPUUsage float64
	// reclaim pool size
	Size int
	// reclaimedCoresSupply is the actual CPU resource can be supplied to reclaimed cores
	ReclaimedCoresSupply float64
}

func GetReclaimMetrics

func GetReclaimMetrics(cpus machine.CPUSet, cgroupPath string, metricsFetcher types.MetricsFetcher) (*ReclaimMetrics, error)

GetReclaimMetrics returns the reclaim CPU metrics for the given cpus and cgroupPath