package network

import "k8s.io/kubernetes/test/e2e/upgrades/network"

Index ¶

• type KubeProxyDowngradeTest
• func (KubeProxyDowngradeTest) Name() string
• func (t *KubeProxyDowngradeTest) Setup(ctx context.Context, f *framework.Framework)
• func (t *KubeProxyDowngradeTest) Teardown(ctx context.Context, f *framework.Framework)
• func (t *KubeProxyDowngradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type KubeProxyUpgradeTest
• func (KubeProxyUpgradeTest) Name() string
• func (t *KubeProxyUpgradeTest) Setup(ctx context.Context, f *framework.Framework)
• func (t *KubeProxyUpgradeTest) Teardown(ctx context.Context, f *framework.Framework)
• func (t *KubeProxyUpgradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type ServiceUpgradeTest
• func (ServiceUpgradeTest) Name() string
• func (t *ServiceUpgradeTest) Setup(ctx context.Context, f *framework.Framework)
• func (t *ServiceUpgradeTest) Teardown(ctx context.Context, f *framework.Framework)
• func (t *ServiceUpgradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)

Types ¶

type KubeProxyDowngradeTest ¶

type KubeProxyDowngradeTest struct {
}

KubeProxyDowngradeTest tests kube-proxy DaemonSet -> static pods downgrade path.

func (KubeProxyDowngradeTest) Name ¶

func (KubeProxyDowngradeTest) Name() string

Name returns the tracking name of the test.

func (*KubeProxyDowngradeTest) Setup ¶

func (t *KubeProxyDowngradeTest) Setup(ctx context.Context, f *framework.Framework)

Setup verifies kube-proxy DaemonSet is running before upgrade.

func (*KubeProxyDowngradeTest) Teardown ¶

func (t *KubeProxyDowngradeTest) Teardown(ctx context.Context, f *framework.Framework)

Teardown does nothing.

func (*KubeProxyDowngradeTest) Test ¶

func (t *KubeProxyDowngradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)

Test validates if kube-proxy is migrated from DaemonSet to static pods.

type KubeProxyUpgradeTest ¶

type KubeProxyUpgradeTest struct {
}

KubeProxyUpgradeTest tests kube-proxy static pods -> DaemonSet upgrade path.

func (KubeProxyUpgradeTest) Name ¶

func (KubeProxyUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*KubeProxyUpgradeTest) Setup ¶

func (t *KubeProxyUpgradeTest) Setup(ctx context.Context, f *framework.Framework)

Setup verifies kube-proxy static pods is running before upgrade.

func (*KubeProxyUpgradeTest) Teardown ¶

func (t *KubeProxyUpgradeTest) Teardown(ctx context.Context, f *framework.Framework)

Teardown does nothing.

func (*KubeProxyUpgradeTest) Test ¶

func (t *KubeProxyUpgradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)

Test validates if kube-proxy is migrated from static pods to DaemonSet.

type ServiceUpgradeTest ¶

type ServiceUpgradeTest struct {
	// contains filtered or unexported fields
}

ServiceUpgradeTest tests that a service is available before and after a cluster upgrade. During a master-only upgrade, it will test that a service remains available during the upgrade.

func (ServiceUpgradeTest) Name ¶

func (ServiceUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*ServiceUpgradeTest) Setup ¶

func (t *ServiceUpgradeTest) Setup(ctx context.Context, f *framework.Framework)

Setup creates a service with a load balancer and makes sure it's reachable.

func (*ServiceUpgradeTest) Teardown ¶

func (t *ServiceUpgradeTest) Teardown(ctx context.Context, f *framework.Framework)

Teardown cleans up any remaining resources.

func (*ServiceUpgradeTest) Test ¶

func (t *ServiceUpgradeTest) Test(ctx context.Context, f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)

Test runs a connectivity check to the service.

Source Files ¶

kube_proxy_migration.go services.go