util

package

v0.1.0-gcp Latest Latest Go to latest Published: Jun 1, 2022 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

README ¶

Utilities

Name	Description
helper	Provides options management, high level validations, and handling of generic non-cloud specific resources.
provisioner	K8ssandra provisioning referencing portions of K8ssandra e2e test framework along with TerraForm and TerraTest modules. Central provisioning logic for management and validation of installation milestones.
cloud	Package where cloud-specific helpers and provisioners reside. For example, `aws`, `azure`, and `gcp`.

Documentation ¶

Index ¶

Constants
func AddServiceAccount(t *testing.T, ctxOption model.ContextOption, namespace string, ...)
func Apply(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig)
func Cleanup(t *testing.T, meta model.ProvisionMeta, name string, ...) bool
func ConfigCloudTempRootPath(t *testing.T, contextOption model.ContextOption, fileName string) string
func ConfigRootPath(t *testing.T, contextOption model.ContextOption, fileName string) string
func CreateClientConfigurations(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig, ...)
func CreateConfigs(t *testing.T, ctxOptions map[string]model.ContextOption, ...)
func CreateContextOptions(t *testing.T, readinessConfig model.ReadinessConfig, ...) map[string]model.ContextOption
func CreateGenericSecret(t *testing.T, namespace string, kubeConfig *k8s.KubectlOptions)
func CreateIdentityEnv(configPath string, identity string, credPath string) map[string]string
func CreateTerraformOptions(meta model.ProvisionMeta, config model.ReadinessConfig, name string, ...) terraform.Options
func DeleteResource(t *testing.T, kubeConfig *k8s.KubectlOptions, resourceKind string, ...)
func FetchCertificate(t *testing.T, options *k8s.KubectlOptions, secret string, namespace string) ([]byte, error)
func FetchEnv(t *testing.T, key string) string
func FetchKubeConfigPath(t *testing.T) (string, string)
func FetchSecret(t *testing.T, options *k8s.KubectlOptions, serviceAccount string, ...) string
func FetchToken(t *testing.T, options *k8s.KubectlOptions, secret string, namespace string) string
func GenerateClientConfig(t *testing.T, ctxOption model.ContextOption) string
func InstallK8ssandra(t *testing.T, readinessConfig model.ReadinessConfig, meta model.ProvisionMeta)
func InstallSetup(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig) map[string]model.ContextOption
func IsControlPlane(ctxConfig model.ContextConfig) bool
func IsPodRunning(t *testing.T, options *k8s.KubectlOptions, prefixName string) (bool, string)
func PreInstallSetup(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig)
func ProvisionMultiCluster(t *testing.T, readinessConfig model.ReadinessConfig, ...) model.ProvisionMeta
func RemoveProvisioningArtifacts(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig, ...)
func RestartCassOperator(t *testing.T, namespace string, options *k8s.KubectlOptions)
func RestartOperator(t *testing.T, namespace string, options *k8s.KubectlOptions)
func SelectClusterFromKube(t *testing.T, name string, configs map[string]*k8s.KubectlOptions) *api.Cluster
func SetCurrentContext(t *testing.T, ctxName string, kubeConfig *k8s.KubectlOptions) bool
func SetupTestArtifactDirectory(t *testing.T, ctxOption model.ContextOption)
func WaitForEndpoint(t *testing.T, kubeConfig *k8s.KubectlOptions, name string) string
func WriteClientConfig(t *testing.T, ctxOption model.ContextOption, clientConfig model.ClientConfig) string
func WriteKubeConfig(t *testing.T, ctxOption model.ContextOption, clientConfig v1.Config) string

Constants ¶

View Source

const (
	DefaultAdminIdentifier = "K8C_ADMIN_ID"
	DefaultTraefikVersion  = "v10.3.2"
)

Variables ¶

This section is empty.

Functions ¶

func AddServiceAccount ¶

func AddServiceAccount(t *testing.T, ctxOption model.ContextOption, namespace string,
	kubeConfig *k8s.KubectlOptions)

func Apply ¶

func Apply(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig)

Apply based on provision meta and configuration settings

func Cleanup ¶

func Cleanup(t *testing.T, meta model.ProvisionMeta, name string, options *terraform.Options) bool

func ConfigCloudTempRootPath ¶

func ConfigCloudTempRootPath(t *testing.T, contextOption model.ContextOption, fileName string) string

func ConfigRootPath ¶

func ConfigRootPath(t *testing.T, contextOption model.ContextOption, fileName string) string

func CreateClientConfigurations ¶

func CreateClientConfigurations(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig,
	ctxOptions map[string]model.ContextOption)

func CreateConfigs ¶

func CreateConfigs(t *testing.T, ctxOptions map[string]model.ContextOption, readinessConfig model.ReadinessConfig)

func CreateContextOptions ¶

func CreateContextOptions(t *testing.T, readinessConfig model.ReadinessConfig,
	provisionMeta model.ProvisionMeta, configs map[string]*k8s.KubectlOptions) map[string]model.ContextOption

func CreateGenericSecret ¶

func CreateGenericSecret(t *testing.T, namespace string, kubeConfig *k8s.KubectlOptions)

func CreateIdentityEnv ¶

func CreateIdentityEnv(configPath string, identity string, credPath string) map[string]string

func CreateTerraformOptions ¶

func CreateTerraformOptions(meta model.ProvisionMeta, config model.ReadinessConfig,
	name string, ctx model.ContextConfig, kubeConfigPath string, rootFolder string) terraform.Options

func DeleteResource ¶

func DeleteResource(t *testing.T, kubeConfig *k8s.KubectlOptions, resourceKind string, resourceName string)

func FetchCertificate ¶

func FetchCertificate(t *testing.T, options *k8s.KubectlOptions, secret string, namespace string) ([]byte, error)

func FetchEnv ¶

func FetchEnv(t *testing.T, key string) string

func FetchKubeConfigPath ¶

func FetchKubeConfigPath(t *testing.T) (string, string)

func FetchSecret ¶

func FetchSecret(t *testing.T, options *k8s.KubectlOptions, serviceAccount string, namespace string) string

func FetchToken ¶

func FetchToken(t *testing.T, options *k8s.KubectlOptions, secret string, namespace string) string

func GenerateClientConfig ¶

func GenerateClientConfig(t *testing.T, ctxOption model.ContextOption) string

func InstallK8ssandra ¶

func InstallK8ssandra(t *testing.T, readinessConfig model.ReadinessConfig, meta model.ProvisionMeta)

func InstallSetup ¶

func InstallSetup(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig) map[string]model.ContextOption

func IsControlPlane ¶

func IsControlPlane(ctxConfig model.ContextConfig) bool

func IsPodRunning ¶

func IsPodRunning(t *testing.T, options *k8s.KubectlOptions, prefixName string) (bool, string)

func PreInstallSetup ¶

func PreInstallSetup(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig)

func ProvisionMultiCluster ¶

func ProvisionMultiCluster(t *testing.T, readinessConfig model.ReadinessConfig,
	provisionMeta model.ProvisionMeta) model.ProvisionMeta

func RemoveProvisioningArtifacts ¶

func RemoveProvisioningArtifacts(t *testing.T, meta model.ProvisionMeta, readinessConfig model.ReadinessConfig,
	isCloudCleanRequested bool)

func RestartCassOperator ¶

func RestartCassOperator(t *testing.T, namespace string, options *k8s.KubectlOptions)

func RestartOperator ¶

func RestartOperator(t *testing.T, namespace string, options *k8s.KubectlOptions)

func SelectClusterFromKube ¶

func SelectClusterFromKube(t *testing.T, name string, configs map[string]*k8s.KubectlOptions) *api.Cluster

func SetCurrentContext ¶

func SetCurrentContext(t *testing.T, ctxName string, kubeConfig *k8s.KubectlOptions) bool

func SetupTestArtifactDirectory ¶

func SetupTestArtifactDirectory(t *testing.T, ctxOption model.ContextOption)

func WaitForEndpoint ¶

func WaitForEndpoint(t *testing.T, kubeConfig *k8s.KubectlOptions, name string) string

func WriteClientConfig ¶

func WriteClientConfig(t *testing.T, ctxOption model.ContextOption, clientConfig model.ClientConfig) string

func WriteKubeConfig ¶

func WriteKubeConfig(t *testing.T, ctxOption model.ContextOption, clientConfig v1.Config) string

Types ¶

This section is empty.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cloud
gcp

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL