ginkgo_util

Documentation

Index

• Constants
• func CreateDockerRegistrySecret(name string, namespace string)
• type NodetoolNodeInfo
• type NsWrapper
  • func NewWrapper(suiteName string, namespace string) NsWrapper
  • func (ns NsWrapper) CqlExecute(podName string, stepDesc string, cql string, user string, pw string)
  • func (ns *NsWrapper) DisableGossip(podName string)
  • func (ns *NsWrapper) DisableGossipWaitNotReady(podName string)
  • func (ns *NsWrapper) EnableGossip(podName string)
  • func (ns *NsWrapper) EnableGossipWaitReady(podName string)
  • func (ns *NsWrapper) ExecAndLog(description string, kcmd kubectl.KCmd)
  • func (ns *NsWrapper) ExecAndLogAndExpectErrorString(description string, kcmd kubectl.KCmd, expectedError string)
  • func (k NsWrapper) ExecV(kcmd kubectl.KCmd) error
  • func (k NsWrapper) ExecVCapture(kcmd kubectl.KCmd) (string, string, error)
  • func (k NsWrapper) ExecVPanic(kcmd kubectl.KCmd)
  • func (ns NsWrapper) ExpectDoneReconciling(dcName string)
  • func (ns NsWrapper) ExpectKeyValue(m map[string]interface{}, key string, expectedValue string)
  • func (ns NsWrapper) ExpectKeyValues(actual map[string]interface{}, expected map[string]string)
  • func (ns *NsWrapper) GetCassandraContainerImages(dcName string) []string
  • func (ns *NsWrapper) GetDatacenterPodNames(dcName string) []string
  • func (ns *NsWrapper) GetDatacenterReadyPodNames(dcName string) []string
  • func (ns *NsWrapper) GetNodeStatusesHostIds(dcName string) []string
  • func (k NsWrapper) Output(kcmd kubectl.KCmd) (string, error)
  • func (ns *NsWrapper) OutputAndLog(description string, kcmd kubectl.KCmd) string
  • func (k NsWrapper) OutputPanic(kcmd kubectl.KCmd) string
  • func (ns NsWrapper) RetrieveStatusFromNodetool(podName string) []NodetoolNodeInfo
  • func (ns NsWrapper) RetrieveSuperuserCreds(clusterName string) (string, string)
  • func (ns NsWrapper) Terminate()
  • func (ns *NsWrapper) WaitForCassandraImages(dcName string, expectedImages []string, timeout int)
  • func (ns *NsWrapper) WaitForDatacenterCondition(dcName string, conditionType string, value string)
  • func (ns *NsWrapper) WaitForDatacenterConditionWithReason(dcName string, conditionType string, value string, reason string)
  • func (ns *NsWrapper) WaitForDatacenterConditionWithTimeout(dcName, conditionType, value string, seconds int)
  • func (ns *NsWrapper) WaitForDatacenterOperatorProgress(dcName string, progressValue string, timeout int)
  • func (ns *NsWrapper) WaitForDatacenterReady(dcName string)
  • func (ns *NsWrapper) WaitForDatacenterReadyPodCount(dcName string, count int)
  • func (ns *NsWrapper) WaitForDatacenterReadyPodCountWithTimeout(dcName string, count int, podCountTimeout int)
  • func (ns *NsWrapper) WaitForDatacenterReadyWithTimeouts(dcName string, podCountTimeout int, dcReadyTimeout int)
  • func (ns *NsWrapper) WaitForDatacenterToHaveNoPods(dcName string)
  • func (ns *NsWrapper) WaitForOperatorReady()
  • func (k NsWrapper) WaitForOutput(kcmd kubectl.KCmd, expected string, seconds int) error
  • func (ns *NsWrapper) WaitForOutputAndLog(description string, kcmd kubectl.KCmd, expected string, seconds int)
  • func (k NsWrapper) WaitForOutputContains(kcmd kubectl.KCmd, expected string, seconds int) error
  • func (ns *NsWrapper) WaitForOutputContainsAndLog(description string, kcmd kubectl.KCmd, expected string, seconds int)
  • func (k NsWrapper) WaitForOutputContainsPanic(kcmd kubectl.KCmd, expected string, seconds int)
  • func (k NsWrapper) WaitForOutputPanic(kcmd kubectl.KCmd, expected string, seconds int)
  • func (k NsWrapper) WaitForOutputPattern(kcmd kubectl.KCmd, pattern string, seconds int) error
  • func (ns *NsWrapper) WaitForOutputPatternAndLog(description string, kcmd kubectl.KCmd, expected string, seconds int)
  • func (ns *NsWrapper) WaitForPodNotStarted(podName string)
  • func (ns *NsWrapper) WaitForPodStarted(podName string)
  • func (ns *NsWrapper) WaitForSuperUserUpserted(dcName string, timeout int)

Constants

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

Functions

func CreateDockerRegistrySecret

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

Types

type NodetoolNodeInfo

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

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

ExecV runs KCmd via `kubectl` in the namspace (the receiver), where KCmd is a struct holding the kubectl command to run (not including `kubectl` itself), the args, and any flags. Returns error only (no capture of results) and also logs logs output.

func (NsWrapper) ExecVCapture

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

ExecVCapture runs KCmd via `kubectl` in the namspace (the receiver), where KCmd is a struct holding the kubectl command to run (not including `kubectl` itself), the args, and any flags. Returns (stdout, stderr, error) and also logs logs output.

func (NsWrapper) ExecVPanic

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

func (NsWrapper) ExpectDoneReconciling

func (ns NsWrapper) ExpectDoneReconciling(dcName string)

func (NsWrapper) ExpectKeyValue

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

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

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) 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

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

func (NsWrapper) RetrieveSuperuserCreds

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

func (NsWrapper) Terminate

func (ns NsWrapper) Terminate()

func (*NsWrapper) WaitForCassandraImages

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

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

func (*NsWrapper) WaitForDatacenterConditionWithTimeout

func (ns *NsWrapper) WaitForDatacenterConditionWithTimeout(dcName, conditionType, value string, seconds int)

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

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

func (*NsWrapper) WaitForDatacenterReadyWithTimeouts

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)