eviction

Documentation

Index

• func NewControllerRecommendationInfoMap(client client.Client, ...) map[string]*controllerRecommendationInfo
• func NewPodReplicaStatus(pods []core_v1.Pod, replicasCount int32, maxUnavailable string) (podReplicaStatus, error)
• type Config
  • func NewDefaultConfig() Config
  • func (c *Config) Validate() error
• type EvictionRestriction
  • func NewEvictionRestriction(client client.Client, maxUnavailable string, triggerThreshold triggerThreshold, ...) EvictionRestriction
• type Evictioner
  • func NewEvictioner(checkCycle int64, datahubClnt datahub_client.DatahubServiceClient, ...) *Evictioner
  • func (evictioner *Evictioner) Start()

Functions

func NewControllerRecommendationInfoMap

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

NewControllerRecommendationInfoMap returns

func NewPodReplicaStatus

func NewPodReplicaStatus(pods []core_v1.Pod, replicasCount int32, maxUnavailable string) (podReplicaStatus, error)

NewPodReplicaStatus build podReplicaStatus by pods and maxUnavailable

Types

type Config

type Config struct {
	CheckCycle              int64 `mapstructure:"checkCycle"`
	Enable                  bool  `mapstructure:"enable"`
	PurgeContainerCPUMemory bool  `mapstructure:"purgeContainerCpuMemory"`
}

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, maxUnavailable string, triggerThreshold triggerThreshold, podRecommendations []*datahub_recommendations.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_client.DatahubServiceClient,
	k8sClienit client.Client,
	evictCfg Config,
	purgeContainerCPUMemory bool,
	clusterID string) *Evictioner

NewEvictioner return Evictioner instance

func (*Evictioner) Start

func (evictioner *Evictioner) Start()

Start checking pods need to apply recommendation