kubernetes/staging/src/k8s.io/kubectl/pkg/drain/filters.go

const daemonSetFatal …

const daemonSetWarning …

const localStorageFatal …

const localStorageWarning …

const unmanagedFatal …

const unmanagedWarning …

type PodDelete …

type PodDeleteList …

// Pods returns a list of all pods marked for deletion after filtering.
func (l *PodDeleteList) Pods() []corev1.Pod { … }

// Warnings returns all warning messages concatenated into a string.
func (l *PodDeleteList) Warnings() string { … }

func (l *PodDeleteList) errors() []error { … }

type PodDeleteStatus …

type PodFilter …

const PodDeleteStatusTypeOkay …

const PodDeleteStatusTypeSkip …

const PodDeleteStatusTypeWarning …

const PodDeleteStatusTypeError …

// MakePodDeleteStatusOkay is a helper method to return the corresponding PodDeleteStatus
func MakePodDeleteStatusOkay() PodDeleteStatus { … }

// MakePodDeleteStatusSkip is a helper method to return the corresponding PodDeleteStatus
func MakePodDeleteStatusSkip() PodDeleteStatus { … }

// MakePodDeleteStatusWithWarning is a helper method to return the corresponding PodDeleteStatus
func MakePodDeleteStatusWithWarning(delete bool, message string) PodDeleteStatus { … }

// MakePodDeleteStatusWithError is a helper method to return the corresponding PodDeleteStatus
func MakePodDeleteStatusWithError(message string) PodDeleteStatus { … }

// The filters are applied in a specific order, only the last filter's
// message will be retained if there are any warnings.
func (d *Helper) makeFilters() []PodFilter { … }

func hasLocalStorage(pod corev1.Pod) bool { … }

func (d *Helper) daemonSetFilter(pod corev1.Pod) PodDeleteStatus { … }

func (d *Helper) mirrorPodFilter(pod corev1.Pod) PodDeleteStatus { … }

func (d *Helper) localStorageFilter(pod corev1.Pod) PodDeleteStatus { … }

func (d *Helper) unreplicatedFilter(pod corev1.Pod) PodDeleteStatus { … }

func shouldSkipPod(pod corev1.Pod, skipDeletedTimeoutSeconds int) bool { … }

func (d *Helper) skipDeletedFilter(pod corev1.Pod) PodDeleteStatus { … }