evictions

Documentation

Index

• func HaveEvictAnnotation(pod *v1.Pod) bool
• func IsPodEvictableBasedOnPriority(pod *v1.Pod, priority int32) bool
• func WithLabelSelector(labelSelector labels.Selector) func(opts *Options)
• func WithNodeFit(nodeFit bool) func(opts *Options)
• func WithPriorityThreshold(priority int32) func(opts *Options)
• type Options
• type PodEvictor
  • func NewPodEvictor(client clientset.Interface, policyGroupVersion string, dryRun bool, ...) *PodEvictor
  • func (pe *PodEvictor) EvictPod(ctx context.Context, pod *v1.Pod, node *v1.Node, strategy string, ...) (bool, error)
  • func (pe *PodEvictor) Evictable(opts ...func(opts *Options)) *evictable
  • func (pe *PodEvictor) NodeEvicted(node *v1.Node) int
  • func (pe *PodEvictor) TotalEvicted() int

Functions

func HaveEvictAnnotation

func HaveEvictAnnotation(pod *v1.Pod) bool

HaveEvictAnnotation checks if the pod have evict annotation

func IsPodEvictableBasedOnPriority

func IsPodEvictableBasedOnPriority(pod *v1.Pod, priority int32) bool

IsPodEvictableBasedOnPriority checks if the given pod is evictable based on priority resolved from pod Spec.

func WithLabelSelector

func WithLabelSelector(labelSelector labels.Selector) func(opts *Options)

WithLabelSelector sets whether or not to apply label filtering when evicting. Any pod matching the label selector is considered evictable.

func WithNodeFit

func WithNodeFit(nodeFit bool) func(opts *Options)

WithNodeFit sets whether or not to consider taints, node selectors, and pod affinity when evicting. A pod whose tolerations, node selectors, and affinity match a node other than the one it is currently running on is evictable.

func WithPriorityThreshold

func WithPriorityThreshold(priority int32) func(opts *Options)

WithPriorityThreshold sets a threshold for pod's priority class. Any pod whose priority class is lower is evictable.

Types

type Options

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

type PodEvictor

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

func NewPodEvictor

func NewPodEvictor(
	client clientset.Interface,
	policyGroupVersion string,
	dryRun bool,
	maxPodsToEvictPerNode int,
	nodes []*v1.Node,
	evictLocalStoragePods bool,
	evictSystemCriticalPods bool,
	ignorePvcPods bool,
) *PodEvictor

func (*PodEvictor) EvictPod

func (pe *PodEvictor) EvictPod(ctx context.Context, pod *v1.Pod, node *v1.Node, strategy string, reasons ...string) (bool, error)

EvictPod returns non-nil error only when evicting a pod on a node is not possible (due to maxPodsToEvictPerNode constraint). Success is true when the pod is evicted on the server side.

func (*PodEvictor) Evictable

func (pe *PodEvictor) Evictable(opts ...func(opts *Options)) *evictable

Evictable provides an implementation of IsEvictable(IsEvictable(pod *v1.Pod) bool). The method accepts a list of options which allow to extend constraints which decides when a pod is considered evictable.

func (*PodEvictor) NodeEvicted

func (pe *PodEvictor) NodeEvicted(node *v1.Node) int

NodeEvicted gives a number of pods evicted for node

func (*PodEvictor) TotalEvicted

func (pe *PodEvictor) TotalEvicted() int

TotalEvicted gives a number of pods evicted through all nodes