apps

package
v1.31.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 19, 2024 License: Apache-2.0 Imports: 33 Imported by: 47

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CassandraUpgradeTest added in v1.21.0 

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

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

func (CassandraUpgradeTest) Name added in v1.21.0 

func (CassandraUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*CassandraUpgradeTest) Setup added in v1.21.0 

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 added in v1.21.0 

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

Skip returns true when this test can be skipped.

func (*CassandraUpgradeTest) Teardown added in v1.21.0 

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

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

func (*CassandraUpgradeTest) Test added in v1.21.0 

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 added in v1.21.0 

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

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

func (EtcdUpgradeTest) Name added in v1.21.0 

func (EtcdUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*EtcdUpgradeTest) Setup added in v1.21.0 

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 added in v1.21.0 

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

Skip returns true when this test can be skipped.

func (*EtcdUpgradeTest) Teardown added in v1.21.0 

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

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

func (*EtcdUpgradeTest) Test added in v1.21.0 

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 added in v1.21.0 

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

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

func (MySQLUpgradeTest) Name added in v1.21.0 

func (MySQLUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*MySQLUpgradeTest) Setup added in v1.21.0 

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 added in v1.21.0 

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

Skip returns true when this test can be skipped.

func (*MySQLUpgradeTest) Teardown added in v1.21.0 

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

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

func (*MySQLUpgradeTest) Test added in v1.21.0 

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 added in v1.9.0 

type ReplicaSetUpgradeTest struct {
	UID types.UID
}

ReplicaSetUpgradeTest tests that a replicaset survives upgrade.

func (ReplicaSetUpgradeTest) Name added in v1.9.0 

func (ReplicaSetUpgradeTest) Name() string

Name returns the tracking name of the test.

func (*ReplicaSetUpgradeTest) Setup added in v1.9.0 

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

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

func (*ReplicaSetUpgradeTest) Teardown added in v1.9.0 

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

Teardown cleans up any remaining resources.

func (*ReplicaSetUpgradeTest) Test added in v1.9.0 

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.