eviction

Documentation

Index

• func NewControllerRecommendationInfoMap(client client.Client, podRecommendations []*datahub_v1alpha1.PodRecommendation) map[string]*controllerRecommendationInfo
• type Config
  • func NewDefaultConfig() Config
  • func (c *Config) Validate() error
• type EvictionRestriction
  • func NewEvictionRestriction(client client.Client, preservationPercentage float64, ...) EvictionRestriction
• type Evictioner
  • func NewEvictioner(checkCycle int64, datahubClnt datahub_v1alpha1.DatahubServiceClient, ...) *Evictioner
  • func (evictioner *Evictioner) Start()

Functions

func NewControllerRecommendationInfoMap

func NewControllerRecommendationInfoMap(client client.Client, podRecommendations []*datahub_v1alpha1.PodRecommendation) map[string]*controllerRecommendationInfo

Types

type Config

type Config struct {
	CheckCycle              int64            `mapstructure:"check-cycle"`
	Enable                  bool             `mapstructure:"enable"`
	TriggerThreshold        triggerThreshold `mapstructure:"trigger-threshold"`
	PurgeContainerCPUMemory bool             `mapstructure:"purge-container-cpu-memory"`
}

Config is eviction configuration

func NewDefaultConfig

func NewDefaultConfig() Config

NewDefaultConfig returns Config instance

func (*Config) Validate

func (c *Config) Validate() error

type EvictionRestriction

type EvictionRestriction interface {
	IsEvictabel(pod *core_v1.Pod) (isEvictabel bool, err error)
}

func NewEvictionRestriction

func NewEvictionRestriction(client client.Client, preservationPercentage float64, triggerThreshold triggerThreshold, podRecommendations []*datahub_v1alpha1.PodRecommendation) EvictionRestriction

type Evictioner

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

Evictioner deletes pods which need to apply recommendation

func NewEvictioner

func NewEvictioner(checkCycle int64,
	datahubClnt datahub_v1alpha1.DatahubServiceClient,
	k8sClienit client.Client,
	evictCfg Config,
	purgeContainerCPUMemory bool) *Evictioner

NewEvictioner return Evictioner instance

func (*Evictioner) Start

func (evictioner *Evictioner) Start()

Start checking pods need to apply recommendation