ginkgo_util

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2021 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EnvNoCleanup        = "M_NO_CLEANUP"
	ImagePullSecretName = "imagepullsecret"
)

Variables

This section is empty.

Functions

func CreateDockerRegistrySecret added in v1.5.0 

func CreateDockerRegistrySecret(name string, namespace string)

kubectl create secret docker-registry github-docker-registry --docker-username=USER --docker-password=PASS --docker-server docker.pkg.github.com

func HelmInstallWithOverrides added in v1.5.0 

func HelmInstallWithOverrides(chartPath string, namespace string, overrides map[string]string)

This is not a method on NsWrapper to allow mage to use it to create an example cluster.

func HelmUpgradeWithOverrides added in v1.5.0 

func HelmUpgradeWithOverrides(chartPath string, namespace string, overrides map[string]string)

Types

type NodetoolNodeInfo added in v1.5.0 

type NodetoolNodeInfo struct {
	Status  string
	State   string
	Address string
	HostId  string
	Rack    string
}

type NsWrapper 

type NsWrapper struct {
	Namespace     string
	TestSuiteName string
	LogDir        string
	// contains filtered or unexported fields
}

Wrapper type to make it simpler to set a namespace one time and execute all of your KCmd objects inside of it, and then use Gomega assertions on panic

func NewWrapper 

func NewWrapper(suiteName string, namespace string) NsWrapper

func (NsWrapper) CqlExecute added in v1.5.0 

func (ns NsWrapper) CqlExecute(podName string, stepDesc string, cql string, user string, pw string)

func (*NsWrapper) DisableGossip 

func (ns *NsWrapper) DisableGossip(podName string)

func (*NsWrapper) DisableGossipWaitNotReady 

func (ns *NsWrapper) DisableGossipWaitNotReady(podName string)

func (*NsWrapper) EnableGossip 

func (ns *NsWrapper) EnableGossip(podName string)

func (*NsWrapper) EnableGossipWaitReady 

func (ns *NsWrapper) EnableGossipWaitReady(podName string)

func (*NsWrapper) ExecAndLog 

func (ns *NsWrapper) ExecAndLog(description string, kcmd kubectl.KCmd)

func (*NsWrapper) ExecAndLogAndExpectErrorString 

func (ns *NsWrapper) ExecAndLogAndExpectErrorString(description string, kcmd kubectl.KCmd, expectedError string)

func (NsWrapper) ExecV 

func (k NsWrapper) ExecV(kcmd kubectl.KCmd) error

func (NsWrapper) ExecVCapture 

func (k NsWrapper) ExecVCapture(kcmd kubectl.KCmd) (string, string, error)

func (NsWrapper) ExecVPanic 

func (k NsWrapper) ExecVPanic(kcmd kubectl.KCmd)

func (NsWrapper) ExpectDoneReconciling added in v1.5.0 

func (ns NsWrapper) ExpectDoneReconciling(dcName string)

func (NsWrapper) ExpectKeyValue added in v1.4.0 

func (ns NsWrapper) ExpectKeyValue(m map[string]interface{}, key string, expectedValue string)

Note that the actual value will be cast to a string before the comparison with the expectedValue

func (NsWrapper) ExpectKeyValues added in v1.4.0 

func (ns NsWrapper) ExpectKeyValues(actual map[string]interface{}, expected map[string]string)

Compare all key/values from an expected map to an actual map

func (*NsWrapper) GetCassandraContainerImages added in v1.5.0 

func (ns *NsWrapper) GetCassandraContainerImages(dcName string) []string

func (*NsWrapper) GetDatacenterPodNames 

func (ns *NsWrapper) GetDatacenterPodNames(dcName string) []string

func (*NsWrapper) GetDatacenterReadyPodNames 

func (ns *NsWrapper) GetDatacenterReadyPodNames(dcName string) []string

func (*NsWrapper) GetNodeStatusesHostIds 

func (ns *NsWrapper) GetNodeStatusesHostIds(dcName string) []string

func (NsWrapper) HelmInstall 

func (ns NsWrapper) HelmInstall(chartPath string, overrides ...string)

func (NsWrapper) HelmInstallWithPSPEnabled added in v1.5.0 

func (ns NsWrapper) HelmInstallWithPSPEnabled(chartPath string)

func (NsWrapper) Output 

func (k NsWrapper) Output(kcmd kubectl.KCmd) (string, error)

func (*NsWrapper) OutputAndLog 

func (ns *NsWrapper) OutputAndLog(description string, kcmd kubectl.KCmd) string

func (NsWrapper) OutputPanic 

func (k NsWrapper) OutputPanic(kcmd kubectl.KCmd) string

func (NsWrapper) RetrieveStatusFromNodetool added in v1.5.0 

func (ns NsWrapper) RetrieveStatusFromNodetool(podName string) []NodetoolNodeInfo

func (NsWrapper) RetrieveSuperuserCreds added in v1.5.0 

func (ns NsWrapper) RetrieveSuperuserCreds(clusterName string) (string, string)

func (NsWrapper) Terminate 

func (ns NsWrapper) Terminate()

func (*NsWrapper) WaitForCassandraImages added in v1.5.0 

func (ns *NsWrapper) WaitForCassandraImages(dcName string, expectedImages []string, timeout int)

func (*NsWrapper) WaitForDatacenterCondition 

func (ns *NsWrapper) WaitForDatacenterCondition(dcName string, conditionType string, value string)

func (*NsWrapper) WaitForDatacenterConditionWithReason added in v1.5.0 

func (ns *NsWrapper) WaitForDatacenterConditionWithReason(dcName string, conditionType string, value string, reason string)

func (*NsWrapper) WaitForDatacenterOperatorProgress 

func (ns *NsWrapper) WaitForDatacenterOperatorProgress(dcName string, progressValue string, timeout int)

func (*NsWrapper) WaitForDatacenterReady 

func (ns *NsWrapper) WaitForDatacenterReady(dcName string)

func (*NsWrapper) WaitForDatacenterReadyPodCount 

func (ns *NsWrapper) WaitForDatacenterReadyPodCount(dcName string, count int)

func (*NsWrapper) WaitForDatacenterReadyPodCountWithTimeout added in v1.4.1 

func (ns *NsWrapper) WaitForDatacenterReadyPodCountWithTimeout(dcName string, count int, podCountTimeout int)

func (*NsWrapper) WaitForDatacenterReadyWithTimeouts added in v1.4.1 

func (ns *NsWrapper) WaitForDatacenterReadyWithTimeouts(dcName string, podCountTimeout int, dcReadyTimeout int)

func (*NsWrapper) WaitForDatacenterToHaveNoPods 

func (ns *NsWrapper) WaitForDatacenterToHaveNoPods(dcName string)

func (*NsWrapper) WaitForOperatorReady 

func (ns *NsWrapper) WaitForOperatorReady()

func (NsWrapper) WaitForOutput 

func (k NsWrapper) WaitForOutput(kcmd kubectl.KCmd, expected string, seconds int) error

func (*NsWrapper) WaitForOutputAndLog 

func (ns *NsWrapper) WaitForOutputAndLog(description string, kcmd kubectl.KCmd, expected string, seconds int)

func (NsWrapper) WaitForOutputContains 

func (k NsWrapper) WaitForOutputContains(kcmd kubectl.KCmd, expected string, seconds int) error

func (*NsWrapper) WaitForOutputContainsAndLog 

func (ns *NsWrapper) WaitForOutputContainsAndLog(description string, kcmd kubectl.KCmd, expected string, seconds int)

func (NsWrapper) WaitForOutputContainsPanic 

func (k NsWrapper) WaitForOutputContainsPanic(kcmd kubectl.KCmd, expected string, seconds int)

func (NsWrapper) WaitForOutputPanic 

func (k NsWrapper) WaitForOutputPanic(kcmd kubectl.KCmd, expected string, seconds int)

func (NsWrapper) WaitForOutputPattern 

func (k NsWrapper) WaitForOutputPattern(kcmd kubectl.KCmd, pattern string, seconds int) error

func (*NsWrapper) WaitForOutputPatternAndLog 

func (ns *NsWrapper) WaitForOutputPatternAndLog(description string, kcmd kubectl.KCmd, expected string, seconds int)

func (*NsWrapper) WaitForPodNotStarted 

func (ns *NsWrapper) WaitForPodNotStarted(podName string)

func (*NsWrapper) WaitForPodStarted 

func (ns *NsWrapper) WaitForPodStarted(podName string)

func (*NsWrapper) WaitForSuperUserUpserted 

func (ns *NsWrapper) WaitForSuperUserUpserted(dcName string, timeout int)

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.