scaling

Documentation

Overview

Package scaling abstracts interactions with the Kubernetes scale API, providing a consistent way to scale resources that are supported by the Custom Pod Autoscaler.

Index

• type Scale
  • func (s *Scale) GetScaleSubResource(apiVersion string, kind string, namespace string, name string) (*autoscalingv1.Scale, error)
  • func (s *Scale) Scale(info scale.Info, scaleResource *autoscalingv1.Scale) (*evaluate.Evaluation, error)
• type Scaler
• type TimestampedEvaluation

Types

type Scale

type Scale struct {
	Scaler                   k8sscale.ScalesGetter
	Config                   *config.Config
	Execute                  execute.Executer
	StabilizationEvaluations []TimestampedEvaluation
}

Scale interacts with the Kubernetes API to allow scaling on evaluations

func (*Scale) GetScaleSubResource

func (s *Scale) GetScaleSubResource(apiVersion string, kind string, namespace string, name string) (*autoscalingv1.Scale, error)

GetScaleSubResource returns the scale subresource from the K8s scale API

func (*Scale) Scale

func (s *Scale) Scale(info scale.Info, scaleResource *autoscalingv1.Scale) (*evaluate.Evaluation, error)

Scale takes an evaluation and uses it to interact with the Kubernetes scaling API, to scale up/down, or keep the same number of replicas for a resource

type Scaler

type Scaler interface {
	Scale(info scale.Info, scaleResource *autoscalingv1.Scale) (*evaluate.Evaluation, error)
	GetScaleSubResource(apiVersion string, kind string, namespace string, name string) (*autoscalingv1.Scale, error)
}

Scaler abstracts interactions with the Kubernetes scale API, allowing scaling based on an evaluation provided

type TimestampedEvaluation

type TimestampedEvaluation struct {
	Time       time.Time
	Evaluation evaluate.Evaluation
}

TimestampedEvaluation is used to associate an evaluation with a timestamp, used in stabilizing evaluations with the downscale stabilization window