drain

Documentation

Index

• Constants
• func ControllerRef(pod *apiv1.Pod) *metav1.OwnerReference
• func GetPodsForDeletionOnNodeDrain(podList []*apiv1.Pod, pdbs []*policyv1.PodDisruptionBudget, deleteAll bool, ...) ([]*apiv1.Pod, error)
• func HasLocalStorage(pod *apiv1.Pod) bool
• func IsMirrorPod(pod *apiv1.Pod) bool

Constants

const (
	// PodDeletionTimeout - time after which a pod to be deleted is not included in the list of pods for drain.
	PodDeletionTimeout = 12 * time.Minute
)

const (
	// PodSafeToEvictKey - annotation that ignores constraints to evict a pod like not being replicated, being on
	// kube-system namespace or having a local storage.
	PodSafeToEvictKey = "cluster-autoscaler.kubernetes.io/safe-to-evict"
)

Functions

func ControllerRef

func ControllerRef(pod *apiv1.Pod) *metav1.OwnerReference

ControllerRef returns the OwnerReference to pod's controller.

func GetPodsForDeletionOnNodeDrain

func GetPodsForDeletionOnNodeDrain(
	podList []*apiv1.Pod,
	pdbs []*policyv1.PodDisruptionBudget,
	deleteAll bool,
	skipNodesWithSystemPods bool,
	skipNodesWithLocalStorage bool,
	checkReferences bool,
	client client.Interface,
	minReplica int32,
	currentTime time.Time) ([]*apiv1.Pod, error)

GetPodsForDeletionOnNodeDrain returns pods that should be deleted on node drain as well as some extra information about possibly problematic pods (unreplicated and daemonsets).

func HasLocalStorage

func HasLocalStorage(pod *apiv1.Pod) bool

HasLocalStorage returns true if pod has any local storage.

func IsMirrorPod

func IsMirrorPod(pod *apiv1.Pod) bool

IsMirrorPod checks whether the pod is a mirror pod.