model

Documentation

Index

• Variables
• func GetEstimatedNodePlatformPower(nodeMetrics *collector_metric.NodeMetrics) (platformEnergy map[string]float64)
• func GetNodeComponentPowers(nodeMetrics *collector_metric.NodeMetrics) (nodeComponentsEnergy map[int]source.NodeComponentsEnergy)
• func InitContainerPowerEstimator(usageMetrics, systemFeatures, systemValues []string)
• func InitEstimateFunctions(usageMetrics, systemFeatures, systemValues []string)
• func InitModelConfig(modelItem string) types.ModelConfig
• func InitNodeComponentPowerEstimator(usageMetrics, systemFeatures, systemValues []string)
• func InitNodeTotalPowerEstimator(usageMetrics, systemFeatures, systemValues []string)
• func InitProcessPowerEstimator(usageMetrics, systemFeatures, systemValues []string)
• func IsNodeComponentPowerModelEnabled() bool
• func IsNodePlatformPowerModelEnabled() bool
• func UpdateContainerEnergy(containersMetrics map[string]*collector_metric.ContainerMetrics, ...)
• func UpdateContainerEnergyByTrainedPowerModel(containersMetrics map[string]*collector_metric.ContainerMetrics)
• func UpdateProcessEnergy(processMetrics map[uint64]*collector_metric.ProcessMetrics, ...)

Variables

var (
	ContainerTotalPowerModelValid, ContainerComponentPowerModelValid bool
	ContainerTotalPowerModelFunc                                     func([][]float64, []string) ([]float64, error)
	ContainerComponentPowerModelFunc                                 func([][]float64, []string) (map[string][]float64, error)
)

var (
	NodeComponentPowerModelEnabled bool
	NodeComponentPowerModelFunc    func([][]float64, []string) (map[string][]float64, error)
)

var (
	NodePlatformPowerModelEnabled bool
	NodeTotalPowerModelFunc       func([][]float64, []string) ([]float64, error)
)

var (
	ProcessTotalPowerModelValid, ProcessComponentPowerModelValid bool
	ProcessTotalPowerModelFunc                                   func([][]float64, []string) ([]float64, error)
	ProcessComponentPowerModelFunc                               func([][]float64, []string) (map[string][]float64, error)
)

var (
	EstimatorSidecarSocket = "/tmp/estimator.sock"
)

Functions

func GetEstimatedNodePlatformPower

func GetEstimatedNodePlatformPower(nodeMetrics *collector_metric.NodeMetrics) (platformEnergy map[string]float64)

GetNodeTotalEnergy returns a single estimated value of node total power

func GetNodeComponentPowers

func GetNodeComponentPowers(nodeMetrics *collector_metric.NodeMetrics) (nodeComponentsEnergy map[int]source.NodeComponentsEnergy)

GetNodeComponentPowers returns estimated RAPL power for the node

func InitContainerPowerEstimator

func InitContainerPowerEstimator(usageMetrics, systemFeatures, systemValues []string)

func InitEstimateFunctions

func InitEstimateFunctions(usageMetrics, systemFeatures, systemValues []string)

InitEstimateFunctions checks validity of power model and set estimate functions

func InitModelConfig

func InitModelConfig(modelItem string) types.ModelConfig

func InitNodeComponentPowerEstimator

func InitNodeComponentPowerEstimator(usageMetrics, systemFeatures, systemValues []string)

func InitNodeTotalPowerEstimator

func InitNodeTotalPowerEstimator(usageMetrics, systemFeatures, systemValues []string)

func InitProcessPowerEstimator

func InitProcessPowerEstimator(usageMetrics, systemFeatures, systemValues []string)

func IsNodeComponentPowerModelEnabled

func IsNodeComponentPowerModelEnabled() bool

IsNodeComponentPowerModelEnabled returns if the estimator has been enabled or not

func IsNodePlatformPowerModelEnabled

func IsNodePlatformPowerModelEnabled() bool

IsNodePlatformPowerModelEnabled returns if the estimator has been enabled or not

func UpdateContainerEnergy

func UpdateContainerEnergy(containersMetrics map[string]*collector_metric.ContainerMetrics, nodeMetrics *collector_metric.NodeMetrics)

UpdateContainerEnergy returns container energy consumption for each node component

func UpdateContainerEnergyByTrainedPowerModel

func UpdateContainerEnergyByTrainedPowerModel(containersMetrics map[string]*collector_metric.ContainerMetrics)

func UpdateProcessEnergy

func UpdateProcessEnergy(processMetrics map[uint64]*collector_metric.ProcessMetrics, systemContainerMetrics *collector_metric.ContainerMetrics)

updateProcessEnergy returns Process energy consumption for each node component