scaling

Documentation

Index

• type ScalingPolicyEvaluator
  • func NewScalingPolicyEvaluator(clock clock.Clock, rule *scalingpolicy.ScalingPolicy) *ScalingPolicyEvaluator
  • func (e *ScalingPolicyEvaluator) AddObservation(inputs factors.Snapshot)
  • func (e *ScalingPolicyEvaluator) ComputeResources(parentPath string, currentPod *v1.PodSpec) (*v1.PodSpec, error)
  • func (e *ScalingPolicyEvaluator) UpdatePolicy(rule *scalingpolicy.ScalingPolicy)

Types

type ScalingPolicyEvaluator

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

func NewScalingPolicyEvaluator

func NewScalingPolicyEvaluator(clock clock.Clock, rule *scalingpolicy.ScalingPolicy) *ScalingPolicyEvaluator

func (*ScalingPolicyEvaluator) AddObservation

func (e *ScalingPolicyEvaluator) AddObservation(inputs factors.Snapshot)

AddObservation is called whenever we observe input values

func (*ScalingPolicyEvaluator) ComputeResources

func (e *ScalingPolicyEvaluator) ComputeResources(parentPath string, currentPod *v1.PodSpec) (*v1.PodSpec, error)

ComputeResources computes a list of resource quantities based on the input state and the specified policy It returns a partial PodSpec with the resources we should apply

func (*ScalingPolicyEvaluator) UpdatePolicy

func (e *ScalingPolicyEvaluator) UpdatePolicy(rule *scalingpolicy.ScalingPolicy)