...

Package network

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

Overview ▾

type KubeProxyDowngradeTest

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

type KubeProxyDowngradeTest struct {
}

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

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

type KubeProxyUpgradeTest struct {
}

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

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.

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

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.