kubernetes – k8s.io/kubernetes/test/e2e/upgrades/apps Index | Files

package apps

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

Index

Types

type CassandraUpgradeTest 

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

CassandraUpgradeTest ups and verifies that a Cassandra StatefulSet behaves well across upgrades.

func (CassandraUpgradeTest) Name 

func (CassandraUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*CassandraUpgradeTest) Setup 

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

Setup creates a Cassandra StatefulSet and a PDB. It also brings up a tester ReplicaSet and associated service and PDB to guarantee availability during the upgrade. It waits for the system to stabilize before adding two users to verify connectivity.

func (CassandraUpgradeTest) Skip 

func (CassandraUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool

Skip returns true when this test can be skipped.

func (*CassandraUpgradeTest) Teardown 

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

Teardown does one final check of the data's availability.

func (*CassandraUpgradeTest) Test 

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

Test is called during the upgrade. It launches two goroutines, one continuously writes to the db and one reads from the db. Each attempt is tallied and at the end we verify if the success ratio is over a certain threshold (0.75). We also verify that we get at least the same number of rows back as we successfully wrote.

type DaemonSetUpgradeTest 

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

DaemonSetUpgradeTest tests that a DaemonSet is running before and after a cluster upgrade.

func (DaemonSetUpgradeTest) Name 

func (DaemonSetUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*DaemonSetUpgradeTest) Setup 

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

Setup creates a DaemonSet and verifies that it's running

func (*DaemonSetUpgradeTest) Teardown 

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

Teardown cleans up any remaining resources.

func (*DaemonSetUpgradeTest) Test 

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

Test waits until the upgrade has completed and then verifies that the DaemonSet is still running

type DeploymentUpgradeTest 

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

DeploymentUpgradeTest tests that a deployment is using the same replica sets before and after a cluster upgrade.

func (DeploymentUpgradeTest) Name 

func (DeploymentUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*DeploymentUpgradeTest) Setup 

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

Setup creates a deployment and makes sure it has a new and an old replicaset running.

func (*DeploymentUpgradeTest) Teardown 

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

Teardown cleans up any remaining resources.

func (*DeploymentUpgradeTest) Test 

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

Test checks whether the replicasets for a deployment are the same after an upgrade.

type EtcdUpgradeTest 

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

EtcdUpgradeTest tests that etcd is writable before and after a cluster upgrade.

func (EtcdUpgradeTest) Name 

func (EtcdUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*EtcdUpgradeTest) Setup 

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

Setup creates etcd statefulset and then verifies that the etcd is writable.

func (EtcdUpgradeTest) Skip 

func (EtcdUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool

Skip returns true when this test can be skipped.

func (*EtcdUpgradeTest) Teardown 

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

Teardown does one final check of the data's availability.

func (*EtcdUpgradeTest) Test 

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

Test waits for upgrade to complete and verifies if etcd is writable.

type JobUpgradeTest 

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

JobUpgradeTest is a test harness for batch Jobs.

func (JobUpgradeTest) Name 

func (JobUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*JobUpgradeTest) Setup 

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

Setup starts a Job with a parallelism of 2 and 2 completions running.

func (*JobUpgradeTest) Teardown 

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

Teardown cleans up any remaining resources.

func (*JobUpgradeTest) Test 

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

Test verifies that the Jobs Pods are running after the an upgrade

type MySQLUpgradeTest 

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

MySQLUpgradeTest implements an upgrade test harness that polls a replicated sql database.

func (MySQLUpgradeTest) Name 

func (MySQLUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*MySQLUpgradeTest) Setup 

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

Setup creates a StatefulSet, HeadlessService, a Service to write to the db, and a Service to read from the db. It then connects to the db with the write Service and populates the db with a table and a few entries. Finally, it connects to the db with the read Service, and confirms the data is available. The db connections are left open to be used later in the test.

func (MySQLUpgradeTest) Skip 

func (MySQLUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool

Skip returns true when this test can be skipped.

func (*MySQLUpgradeTest) Teardown 

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

Teardown performs one final check of the data's availability.

func (*MySQLUpgradeTest) Test 

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

Test continually polls the db using the read and write connections, inserting data, and checking that all the data is readable.

type ReplicaSetUpgradeTest 

type ReplicaSetUpgradeTest struct {
	UID types.UID
}

ReplicaSetUpgradeTest tests that a replicaset survives upgrade.

func (ReplicaSetUpgradeTest) Name 

func (ReplicaSetUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*ReplicaSetUpgradeTest) Setup 

func (r *ReplicaSetUpgradeTest) Setup(ctx context.Context, f *framework.Framework)

Setup creates a ReplicaSet and makes sure it's replicas ready.

func (*ReplicaSetUpgradeTest) Teardown 

func (r *ReplicaSetUpgradeTest) Teardown(ctx context.Context, f *framework.Framework)

Teardown cleans up any remaining resources.

func (*ReplicaSetUpgradeTest) Test 

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

Test checks whether the replicasets are the same after an upgrade.

type StatefulSetUpgradeTest 

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

StatefulSetUpgradeTest implements an upgrade test harness for StatefulSet upgrade testing.

func (StatefulSetUpgradeTest) Name 

func (StatefulSetUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*StatefulSetUpgradeTest) Setup 

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

Setup creates a StatefulSet and a HeadlessService. It verifies the basic SatefulSet properties

func (StatefulSetUpgradeTest) Skip 

func (StatefulSetUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool

Skip returns true when this test can be skipped.

func (*StatefulSetUpgradeTest) Teardown 

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

Teardown deletes all StatefulSets

func (*StatefulSetUpgradeTest) Test 

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

Test waits for the upgrade to complete and verifies the StatefulSet basic functionality

Source Files

cassandra.go daemonsets.go deployments.go etcd.go job.go mysql.go replicasets.go statefulset.go

Version
v1.33.0 (latest)
Published
Apr 23, 2025
Platform
linux/amd64
Imports
34 packages
Last checked
3 hours ago –

Tools for package owners.