kubernetes/test/integration/disruption/disruption_test.go

const stalePodDisruptionTimeout …

func setup(ctx context.Context, t *testing.T) (*kubeapiservertesting.TestServer, *disruption.DisruptionController, informers.SharedInformerFactory, clientset.Interface, *apiextensionsclientset.Clientset, dynamic.Interface) { … }

func TestPDBWithScaleSubresource(t *testing.T) { … }

func TestEmptySelector(t *testing.T) { … }

func TestSelectorsForPodsWithoutLabels(t *testing.T) { … }

func createPod(ctx context.Context, t *testing.T, name, namespace string, labels map[string]string, clientSet clientset.Interface, ownerRefs []metav1.OwnerReference) { … }

func createNs(ctx context.Context, t *testing.T, name string, clientSet clientset.Interface) { … }

func addPodConditionReady(pod *v1.Pod) { … }

func newCustomResourceDefinition() *apiextensionsv1.CustomResourceDefinition { … }

func waitPDBStable(ctx context.Context, t *testing.T, clientSet clientset.Interface, podNum int32, ns, pdbName string) { … }

func waitToObservePods(t *testing.T, podInformer cache.SharedIndexInformer, podNum int, phase v1.PodPhase) { … }

// createPDBUsingRemovedAPI creates a PDB directly using etcd.  This is must *ONLY* be used for checks of compatibility
// with removed data. Do not use this just because you don't want to update your test to use v1.  Only use this
// when it actually matters.
func createPDBUsingRemovedAPI(ctx context.Context, etcdClient *clientv3.Client, etcdStoragePrefix, nsName string, betaPDB *v1beta1.PodDisruptionBudget) error { … }

func TestPatchCompatibility(t *testing.T) { … }

func TestStalePodDisruption(t *testing.T) { … }