Documentation
¶
Index ¶
- Variables
- func CancelRepair(t *testing.T, repairId uuid.UUID)
- func CheckClusterExpectedResources(t *testing.T, namespace string)
- func CheckClusterIsRegisteredInReaper(t *testing.T, clusterName string)
- func CheckGrafanaIsReachable(t *testing.T)
- func CheckK8sClusterIsReachable(t *testing.T)
- func CheckKeyspaceExists(t *testing.T, namespace, keyspace string)
- func CheckLastRestoreFileContainsKey(t *testing.T, namespace string)
- func CheckLastRestoreFilePresence(t *testing.T, namespace string)
- func CheckNamespaceIsAbsent(t *testing.T, namespace string)
- func CheckNamespaceWasCreated(t *testing.T, namespace string)
- func CheckNoOutOfOrderMetrics(t *testing.T, namespace string)
- func CheckPrometheusActiveTargets(t *testing.T, expectedTargets int)
- func CheckPrometheusMetricExtraction(t *testing.T)
- func CheckResourceWithLabelsIsPresent(t *testing.T, namespace, resourceType string, labels map[string]string)
- func CheckRowCountInTable(t *testing.T, nbRows int, namespace, tableName, keyspaceName string)
- func CheckSecretIsPresent(t *testing.T, namespace, secret string)
- func CheckStargateDocumentExists(t *testing.T, token, docNamespace, documentId string)
- func CheckTableLevelMetricsArePresent(t *testing.T)
- func Color(colorString string) func(...interface{}) string
- func CountMonitoredItems(t *testing.T, namespace string) int
- func CountPodsWithLabels(t *testing.T, namespace string, labels map[string]string) int
- func CreateCassandraTable(t *testing.T, namespace, tableName, keyspaceName string)
- func CreateMedusaSecretWithFile(t *testing.T, namespace, secretFile string)
- func CreateNamespace(t *testing.T) string
- func CreateStargateDocumentNamespace(t *testing.T, token string) string
- func DeleteNamespace(t *testing.T, namespace string)
- func DeployClusterWithValues(t *testing.T, namespace, medusaBackend, customValues string, nodes int, ...)
- func DeployMinioAndCreateBucket(t *testing.T, bucketName string)
- func ExtractUsernamePassword(t *testing.T, secretName, namespace string) credentials
- func Find(slice []string, val string) bool
- func GenerateStargateAuthToken(t *testing.T, namespace string) string
- func GetNamespace(name string) (*v1.Namespace, error)
- func GetPodsWithLabels(t *testing.T, namespace string, labels map[string]string) *v1.PodList
- func InitTestClient() error
- func InstallTraefik(t *testing.T)
- func LoadRowsInTable(t *testing.T, nbRows int, namespace, tableName, keyspaceName string)
- func MinioServiceName(t *testing.T) string
- func PerformBackup(t *testing.T, namespace, backupName string, useLocalCharts bool)
- func PodWithLabelsIsReady(t *testing.T, namespace string, label map[string]string) bool
- func RestartStargate(t *testing.T, releaseName, dcName, namespace string)
- func RestoreBackup(t *testing.T, namespace, backupName string)
- func RunShellCommand(command *exec.Cmd) error
- func RunShellCommandAndGetOutput(command *exec.Cmd) string
- func StargateService(t *testing.T, namespace string) (v1.Service, error)
- func TriggerRepair(t *testing.T, clusterName, keyspace, owner string) uuid.UUID
- func UninstallHelmReleaseAndNamespace(t *testing.T, helmReleaseName, namespace string)
- func WaitForAuthEndpoint(t *testing.T)
- func WaitForCassDcToBeReady(t *testing.T, namespace string)
- func WaitForCassDcToBeUpdating(t *testing.T, namespace string)
- func WaitForCassandraDatacenterDeletion(t *testing.T, namespace string)
- func WaitForDeploymentReady(t *testing.T, key types.NamespacedName, retryInterval, timeout time.Duration) bool
- func WaitForOneSegmentToBeDone(t *testing.T, repairId uuid.UUID)
- func WaitForPodWithLabelsToBeReady(t *testing.T, namespace string, labels map[string]string)
- func WaitForReaperPod(t *testing.T, namespace string)
- func WaitForStargatePodReady(t *testing.T, namespace string)
- func WriteStargateDocument(t *testing.T, token, docNamespace string) string
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Info = Color("\033[1;33m%s\033[0m") Outline = Color("\033[1;34m%s\033[0m") Step = Color("\033[1;36m%s\033[0m") Success = Color("\033[1;32m%s\033[0m") )
Functions ¶
func CheckGrafanaIsReachable ¶
func CheckKeyspaceExists ¶
func CheckLastRestoreFileContainsKey ¶ added in v1.4.0
func CheckLastRestoreFilePresence ¶ added in v1.4.0
func CheckNamespaceIsAbsent ¶
func CheckNoOutOfOrderMetrics ¶ added in v1.3.2
func CheckPrometheusActiveTargets ¶
Monitoring related functions
func CheckResourceWithLabelsIsPresent ¶ added in v1.2.0
func CheckRowCountInTable ¶
func CheckSecretIsPresent ¶
func CheckTableLevelMetricsArePresent ¶ added in v1.3.3
func CountPodsWithLabels ¶ added in v1.2.0
func CreateCassandraTable ¶
func CreateNamespace ¶
func DeleteNamespace ¶
func DeployClusterWithValues ¶
func ExtractUsernamePassword ¶
func GetPodsWithLabels ¶ added in v1.3.2
func InitTestClient ¶ added in v1.2.0
func InitTestClient() error
InitTestClient initializes a controller-runtime client. This is a no-op if it has already been called. It should be called prior to any test execution.
func InstallTraefik ¶
func LoadRowsInTable ¶
func MinioServiceName ¶
func PerformBackup ¶
func PodWithLabelsIsReady ¶ added in v1.2.0
func RestartStargate ¶ added in v1.2.0
RestartStargate scales the Stargate deployment down to zero and then scales it back up to the prior number of replicas. This function blocks until the deployment is ready.
func RestoreBackup ¶
func RunShellCommand ¶
func StargateService ¶
Stargate related functions
func TriggerRepair ¶
TriggerRepair starts a repair on keyspace and return the repair id
func UninstallHelmReleaseAndNamespace ¶ added in v1.3.0
func WaitForAuthEndpoint ¶
func WaitForCassDcToBeReady ¶
func WaitForDeploymentReady ¶ added in v1.2.0
func WaitForDeploymentReady(t *testing.T, key types.NamespacedName, retryInterval, timeout time.Duration) bool
WaitForDeploymentReady Polls the deployment status until the Deployment is ready. Readiness is defined as .Status.Replicas == .Status.ReadyReplicas.
func WaitForPodWithLabelsToBeReady ¶ added in v1.2.0
func WaitForReaperPod ¶
func WaitForStargatePodReady ¶
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.