apps

Documentation

Index

• type CassandraUpgradeTest
  • func (CassandraUpgradeTest) Name() string
  • func (t *CassandraUpgradeTest) Setup(f *framework.Framework)
  • func (CassandraUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool
  • func (t *CassandraUpgradeTest) Teardown(f *framework.Framework)
  • func (t *CassandraUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type DaemonSetUpgradeTest
  • func (DaemonSetUpgradeTest) Name() string
  • func (t *DaemonSetUpgradeTest) Setup(f *framework.Framework)
  • func (t *DaemonSetUpgradeTest) Teardown(f *framework.Framework)
  • func (t *DaemonSetUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type DeploymentUpgradeTest
  • func (DeploymentUpgradeTest) Name() string
  • func (t *DeploymentUpgradeTest) Setup(f *framework.Framework)
  • func (t *DeploymentUpgradeTest) Teardown(f *framework.Framework)
  • func (t *DeploymentUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type EtcdUpgradeTest
  • func (EtcdUpgradeTest) Name() string
  • func (t *EtcdUpgradeTest) Setup(f *framework.Framework)
  • func (EtcdUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool
  • func (t *EtcdUpgradeTest) Teardown(f *framework.Framework)
  • func (t *EtcdUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type JobUpgradeTest
  • func (JobUpgradeTest) Name() string
  • func (t *JobUpgradeTest) Setup(f *framework.Framework)
  • func (t *JobUpgradeTest) Teardown(f *framework.Framework)
  • func (t *JobUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type MySQLUpgradeTest
  • func (MySQLUpgradeTest) Name() string
  • func (t *MySQLUpgradeTest) Setup(f *framework.Framework)
  • func (MySQLUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool
  • func (t *MySQLUpgradeTest) Teardown(f *framework.Framework)
  • func (t *MySQLUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type ReplicaSetUpgradeTest
  • func (ReplicaSetUpgradeTest) Name() string
  • func (r *ReplicaSetUpgradeTest) Setup(f *framework.Framework)
  • func (r *ReplicaSetUpgradeTest) Teardown(f *framework.Framework)
  • func (r *ReplicaSetUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)
• type StatefulSetUpgradeTest
  • func (StatefulSetUpgradeTest) Name() string
  • func (t *StatefulSetUpgradeTest) Setup(f *framework.Framework)
  • func (StatefulSetUpgradeTest) Skip(upgCtx upgrades.UpgradeContext) bool
  • func (t *StatefulSetUpgradeTest) Teardown(f *framework.Framework)
  • func (t *StatefulSetUpgradeTest) Test(f *framework.Framework, done <-chan struct{}, upgrade upgrades.UpgradeType)

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(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(f *framework.Framework)

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

func (*CassandraUpgradeTest) Test

func (t *CassandraUpgradeTest) Test(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(f *framework.Framework)

Setup creates a DaemonSet and verifies that it's running

func (*DaemonSetUpgradeTest) Teardown

func (t *DaemonSetUpgradeTest) Teardown(f *framework.Framework)

Teardown cleans up any remaining resources.

func (*DaemonSetUpgradeTest) Test

func (t *DaemonSetUpgradeTest) Test(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(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(f *framework.Framework)

Teardown cleans up any remaining resources.

func (*DeploymentUpgradeTest) Test

func (t *DeploymentUpgradeTest) Test(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(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(f *framework.Framework)

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

func (*EtcdUpgradeTest) Test

func (t *EtcdUpgradeTest) Test(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(f *framework.Framework)

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

func (*JobUpgradeTest) Teardown

func (t *JobUpgradeTest) Teardown(f *framework.Framework)

Teardown cleans up any remaining resources.

func (*JobUpgradeTest) Test

func (t *JobUpgradeTest) Test(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(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(f *framework.Framework)

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

func (*MySQLUpgradeTest) Test

func (t *MySQLUpgradeTest) Test(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(f *framework.Framework)

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

func (*ReplicaSetUpgradeTest) Teardown

func (r *ReplicaSetUpgradeTest) Teardown(f *framework.Framework)

Teardown cleans up any remaining resources.

func (*ReplicaSetUpgradeTest) Test

func (r *ReplicaSetUpgradeTest) Test(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(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(f *framework.Framework)

Teardown deletes all StatefulSets

func (*StatefulSetUpgradeTest) Test

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

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