estimator

Documentation

Index

• Constants
• Variables
• func PodRequestsAndLimits(pod *corev1.Pod) (reqs, limits corev1.ResourceList)
• type DefaultEstimator
  • func (e *DefaultEstimator) EstimateNode(nodeInfo framework.NodeInfo, resourceType podutil.PodResourceType) (*framework.Resource, error)
  • func (e *DefaultEstimator) EstimatePod(pod *corev1.Pod) (*framework.Resource, error)
  • func (e *DefaultEstimator) Name() string
  • func (e *DefaultEstimator) ValidateNode(_ framework.NodeInfo, _ podutil.PodResourceType) *framework.Status
• type Estimator
  • func NewDefaultEstimator(args *config.LoadAwareArgs, handle handle.PodFrameworkHandle) (Estimator, error)
  • func NewEstimator(args *config.LoadAwareArgs, handle handle.PodFrameworkHandle) (Estimator, error)
  • func NewNodeMetricEstimator(args *config.LoadAwareArgs, handle handle.PodFrameworkHandle) (Estimator, error)
• type FactoryFn
• type NodeMetricEstimator
  • func (e *NodeMetricEstimator) EstimateNode(nodeInfo framework.NodeInfo, resourceType podutil.PodResourceType) (*framework.Resource, error)
  • func (e *NodeMetricEstimator) EstimatePod(pod *v1.Pod) (*framework.Resource, error)
  • func (e *NodeMetricEstimator) Name() string
  • func (e *NodeMetricEstimator) ValidateNode(nodeInfo framework.NodeInfo, resourceType podutil.PodResourceType) *framework.Status

Constants

const (
	DefaultEstimatorName = "defaultEstimator"

	// DefaultMilliCPURequest defines default milli cpu request number.
	DefaultMilliCPURequest int64 = 250 // 0.25 core
	// DefaultMemoryRequest defines default memory request size.
	DefaultMemoryRequest int64 = 200 * 1024 * 1024 // 200 MiB
)

const (
	NodeMetricEstimatorName = "nodeMetricEstimator"

	DefaultNodeMetricExpirationSeconds = 30 // TODO: revisit this.
)

Variables

var Estimators = map[string]FactoryFn{
	DefaultEstimatorName:    NewDefaultEstimator,
	NodeMetricEstimatorName: NewNodeMetricEstimator,
}

Functions

func PodRequestsAndLimits

func PodRequestsAndLimits(pod *corev1.Pod) (reqs, limits corev1.ResourceList)

PodRequestsAndLimits returns a dictionary of all defined resources summed up for all containers of the pod. If PodOverhead feature is enabled, pod overhead is added to the total container resource requests and to the total container limits which have a non-zero quantity.

Types

type DefaultEstimator

type DefaultEstimator struct {
	// contains filtered or unexported fields
}

func (*DefaultEstimator) EstimateNode

func (e *DefaultEstimator) EstimateNode(nodeInfo framework.NodeInfo, resourceType podutil.PodResourceType) (*framework.Resource, error)

func (*DefaultEstimator) EstimatePod

func (e *DefaultEstimator) EstimatePod(pod *corev1.Pod) (*framework.Resource, error)

func (*DefaultEstimator) Name

func (e *DefaultEstimator) Name() string

func (*DefaultEstimator) ValidateNode

func (e *DefaultEstimator) ValidateNode(_ framework.NodeInfo, _ podutil.PodResourceType) *framework.Status

type Estimator

type Estimator interface {
	Name() string
	ValidateNode(nodeInfo framework.NodeInfo, resourceType podutil.PodResourceType) *framework.Status
	EstimatePod(pod *corev1.Pod) (*framework.Resource, error)
	EstimateNode(info framework.NodeInfo, resourceType podutil.PodResourceType) (*framework.Resource, error)
}

func NewDefaultEstimator

func NewDefaultEstimator(args *config.LoadAwareArgs, handle handle.PodFrameworkHandle) (Estimator, error)

func NewEstimator

func NewEstimator(args *config.LoadAwareArgs, handle handle.PodFrameworkHandle) (Estimator, error)

func NewNodeMetricEstimator

func NewNodeMetricEstimator(args *config.LoadAwareArgs, handle handle.PodFrameworkHandle) (Estimator, error)

type FactoryFn

type FactoryFn func(args *config.LoadAwareArgs, handle handle.PodFrameworkHandle) (Estimator, error)

type NodeMetricEstimator

type NodeMetricEstimator struct {
	// contains filtered or unexported fields
}

func (*NodeMetricEstimator) EstimateNode

func (e *NodeMetricEstimator) EstimateNode(nodeInfo framework.NodeInfo, resourceType podutil.PodResourceType) (*framework.Resource, error)

func (*NodeMetricEstimator) EstimatePod

func (e *NodeMetricEstimator) EstimatePod(pod *v1.Pod) (*framework.Resource, error)

func (*NodeMetricEstimator) Name

func (e *NodeMetricEstimator) Name() string

func (*NodeMetricEstimator) ValidateNode

func (e *NodeMetricEstimator) ValidateNode(nodeInfo framework.NodeInfo, resourceType podutil.PodResourceType) *framework.Status