kubernetes/test/e2e/apps/disruption.go

const bigClusterSize …

const schedulingTimeout …

const timeout …

const defaultName …

var defaultLabels …

var _ …

func createPDBMinAvailableOrDie(ctx context.Context, cs kubernetes.Interface, ns string, name string, minAvailable intstr.IntOrString, labels map[string]string) { … }

func createPDBMaxUnavailableOrDie(ctx context.Context, cs kubernetes.Interface, ns string, name string, maxUnavailable intstr.IntOrString, unhealthyPodEvictionPolicy *policyv1.UnhealthyPodEvictionPolicyType) { … }

type updateFunc …

type updateRestAPI …

type patchFunc …

func updatePDBOrDie(ctx context.Context, cs kubernetes.Interface, ns string, name string, f updateFunc, api updateRestAPI) (updated *policyv1.PodDisruptionBudget) { … }

func patchPDBOrDie(ctx context.Context, cs kubernetes.Interface, dc dynamic.Interface, ns string, name string, f patchFunc, subresources ...string) (updated *policyv1.PodDisruptionBudget) { … }

func deletePDBOrDie(ctx context.Context, cs kubernetes.Interface, ns string, name string) { … }

func listPDBs(ctx context.Context, cs kubernetes.Interface, ns string, labelSelector string, count int, expectedPDBNames []string) { … }

func deletePDBCollection(ctx context.Context, cs kubernetes.Interface, ns string) { … }

func waitForPDBCollectionToBeDeleted(ctx context.Context, cs kubernetes.Interface, ns string) { … }

func createPodsOrDie(ctx context.Context, cs kubernetes.Interface, ns string, n int) { … }

func waitForPodsOrDie(ctx context.Context, cs kubernetes.Interface, ns string, n int) { … }

func createReplicaSetOrDie(ctx context.Context, cs kubernetes.Interface, ns string, size int32, exclusive bool) { … }

func locateRunningPod(ctx context.Context, cs kubernetes.Interface, ns string) (pod *v1.Pod, err error) { … }

func waitForPdbToBeProcessed(ctx context.Context, cs kubernetes.Interface, ns string, name string) { … }

func waitForPdbToBeDeleted(ctx context.Context, cs kubernetes.Interface, ns string, name string) { … }

func waitForPdbToObserveHealthyPods(ctx context.Context, cs kubernetes.Interface, ns string, healthyCount, desiredHealthy int32) { … }

func getPDBStatusOrDie(ctx context.Context, dc dynamic.Interface, ns string, name string) *policyv1.PodDisruptionBudget { … }

func unstructuredToPDB(obj *unstructured.Unstructured) (*policyv1.PodDisruptionBudget, error) { … }

// isPDBErroring checks if the PDB is erroring on when there are unmanaged pods
func isPDBErroring(pdb *policyv1.PodDisruptionBudget) bool { … }