kubernetes/pkg/registry/core/pod/storage/eviction.go

const MaxDisruptedPodSize …

var EvictionsRetry …

func newEvictionStorage(store rest.StandardStorage, podDisruptionBudgetClient policyclient.PodDisruptionBudgetsGetter) *EvictionREST { … }

type EvictionREST …

var _ …

var _ …

var _ …

var v1Eviction …

// GroupVersionKind specifies a particular GroupVersionKind to discovery
func (r *EvictionREST) GroupVersionKind(containingGV schema.GroupVersion) schema.GroupVersionKind { … }

// AcceptsGroupVersion indicates both v1 and v1beta1 Eviction objects are acceptable
func (r *EvictionREST) AcceptsGroupVersion(gv schema.GroupVersion) bool { … }

// New creates a new eviction resource
func (r *EvictionREST) New() runtime.Object { … }

// Destroy cleans up resources on shutdown.
func (r *EvictionREST) Destroy() { … }

// Propagate dry-run takes the dry-run option from the request and pushes it into the eviction object.
// It returns an error if they have non-matching dry-run options.
func propagateDryRun(eviction *policy.Eviction, options *metav1.CreateOptions) (*metav1.DeleteOptions, error) { … }

// Create attempts to create a new eviction.  That is, it tries to evict a pod.
func (r *EvictionREST) Create(ctx context.Context, name string, obj runtime.Object, createValidation rest.ValidateObjectFunc, options *metav1.CreateOptions) (runtime.Object, error) { … }

func addConditionAndDeletePod(r *EvictionREST, ctx context.Context, name string, validation rest.ValidateObjectFunc, options *metav1.DeleteOptions) error { … }

func getPod(r *EvictionREST, ctx context.Context, name string) (*api.Pod, error) { … }

func setPreconditionsResourceVersion(deleteOptions *metav1.DeleteOptions, resourceVersion *string) { … }

// canIgnorePDB returns true for pod conditions that allow the pod to be deleted
// without checking PDBs.
func canIgnorePDB(pod *api.Pod) bool { … }

func shouldEnforceResourceVersion(pod *api.Pod) bool { … }

func resourceVersionIsUnset(options *metav1.DeleteOptions) bool { … }

func createTooManyRequestsError(name string) error { … }

// checkAndDecrement checks if the provided PodDisruptionBudget allows any disruption.
func (r *EvictionREST) checkAndDecrement(namespace string, podName string, pdb policyv1.PodDisruptionBudget, dryRun bool) error { … }

// getPodDisruptionBudgets returns any PDBs that match the pod or err if there's an error.
func (r *EvictionREST) getPodDisruptionBudgets(ctx context.Context, pod *api.Pod) ([]policyv1.PodDisruptionBudget, error) { … }