kubernetes/test/e2e/upgrades/network/kube_proxy_migration.go

const defaultTestTimeout …

const clusterAddonLabelKey …

const clusterComponentKey …

const kubeProxyLabelName …

type KubeProxyUpgradeTest …

// Name returns the tracking name of the test.
func (KubeProxyUpgradeTest) Name() string { … }

// Setup verifies kube-proxy static pods is running before upgrade.
func (t *KubeProxyUpgradeTest) Setup(ctx context.Context, f *framework.Framework) { … }

// Test validates if kube-proxy is migrated from static pods to DaemonSet.
func (t *KubeProxyUpgradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{ … }

// Teardown does nothing.
func (t *KubeProxyUpgradeTest) Teardown(ctx context.Context, f *framework.Framework) { … }

type KubeProxyDowngradeTest …

// Name returns the tracking name of the test.
func (KubeProxyDowngradeTest) Name() string { … }

// Setup verifies kube-proxy DaemonSet is running before upgrade.
func (t *KubeProxyDowngradeTest) Setup(ctx context.Context, f *framework.Framework) { … }

// Test validates if kube-proxy is migrated from DaemonSet to static pods.
func (t *KubeProxyDowngradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{ … }

// Teardown does nothing.
func (t *KubeProxyDowngradeTest) Teardown(ctx context.Context, f *framework.Framework) { … }

func waitForKubeProxyStaticPodsRunning(ctx context.Context, c clientset.Interface) error { … }

func waitForKubeProxyStaticPodsDisappear(ctx context.Context, c clientset.Interface) error { … }

func waitForKubeProxyDaemonSetRunning(ctx context.Context, f *framework.Framework, c clientset.Interface) error { … }

func waitForKubeProxyDaemonSetDisappear(ctx context.Context, c clientset.Interface) error { … }

func getKubeProxyStaticPods(ctx context.Context, c clientset.Interface) (*v1.PodList, error) { … }

func getKubeProxyDaemonSet(ctx context.Context, c clientset.Interface) (*appsv1.DaemonSetList, error) { … }