installer

package
v1.3.9 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2020 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Version1_2 rook version 1.2
	Version1_2 = "v1.2.7"
	// Version1_3 rook version 1.3
	Version1_3 = "v1.3.1"
)
View Source 
const (
	// VersionMaster tag for the latest manifests
	VersionMaster = "master"

	// test suite names
	CassandraTestSuite   = "cassandra"
	CephTestSuite        = "ceph"
	CockroachDBTestSuite = "cockroachdb"
	EdgeFSTestSuite      = "edgefs"
	NFSTestSuite         = "nfs"
	YugabyteDBTestSuite  = "yugabytedb"
)
View Source 
const (
	CRDFullyQualifiedName         = "ybclusters.yugabytedb.rook.io"
	CRDFullyQualifiedNameSingular = "ybcluster.yugabytedb.rook.io"
)

Variables

View Source 
var (
	NautilusVersion = cephv1.CephVersionSpec{Image: nautilusTestImage}
	OctopusVersion  = cephv1.CephVersionSpec{Image: octopusTestImage}
	MasterVersion   = cephv1.CephVersionSpec{Image: masterTestImage, AllowUnsupported: true}
)

Functions

func InstallHostPathProvisioner added in v0.9.0 

func InstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

************************************************************************************************ HostPath provisioner functions ************************************************************************************************

func IsAdditionalDeviceAvailableOnCluster added in v0.6.0 

func IsAdditionalDeviceAvailableOnCluster() bool

IsAdditionalDeviceAvailableOnCluster checks whether a given device is available to become an OSD

func SkipTestSuite added in v1.3.9 

func SkipTestSuite(name string) bool

func SystemNamespace added in v0.6.0 

func SystemNamespace(namespace string) string

func TestIsOfficialBuild added in v1.3.9 

func TestIsOfficialBuild() bool

TestIsOfficialBuild gets the storage provider for which tests should be run

func TestLogCollectionLevel added in v1.3.9 

func TestLogCollectionLevel() string

TestLogCollectionLevel gets whether to collect all logs

func TestScratchDevice added in v1.3.9 

func TestScratchDevice() string

TestScratchDevice get the scratch device to be used for OSD

func UninstallHostPathProvisioner added in v0.9.0 

func UninstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

Types

type CassandraInstaller added in v0.9.0 

type CassandraInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewCassandraInstaller added in v0.9.0 

func NewCassandraInstaller(k8sHelper *utils.K8sHelper, t func() *testing.T) *CassandraInstaller

func (*CassandraInstaller) CreateCassandraCluster added in v0.9.0 

func (ci *CassandraInstaller) CreateCassandraCluster(namespace string, count int, mode cassandrav1alpha1.ClusterMode) error

func (*CassandraInstaller) CreateCassandraOperator added in v0.9.0 

func (ci *CassandraInstaller) CreateCassandraOperator(namespace string) error

func (*CassandraInstaller) DeleteCassandraCluster added in v0.9.0 

func (ci *CassandraInstaller) DeleteCassandraCluster(namespace string)

func (*CassandraInstaller) GatherAllCassandraLogs added in v0.9.0 

func (ci *CassandraInstaller) GatherAllCassandraLogs(systemNamespace, namespace, testName string)

func (*CassandraInstaller) InstallCassandra added in v0.9.0 

func (ci *CassandraInstaller) InstallCassandra(systemNamespace, namespace string, count int, mode cassandrav1alpha1.ClusterMode) error

func (*CassandraInstaller) UninstallCassandra added in v0.9.0 

func (ci *CassandraInstaller) UninstallCassandra(systemNamespace string, namespace string)

type CassandraManifests added in v0.9.0 

type CassandraManifests struct{}

func (*CassandraManifests) GetCassandraCRDs added in v0.9.0 

func (i *CassandraManifests) GetCassandraCRDs() string

func (*CassandraManifests) GetCassandraCluster added in v0.9.0 

func (i *CassandraManifests) GetCassandraCluster(namespace string, count int, mode cassandrav1alpha1.ClusterMode) string

func (*CassandraManifests) GetCassandraOperator added in v0.9.0 

func (i *CassandraManifests) GetCassandraOperator(namespace string) string

type CephInstaller added in v0.9.0 

type CephInstaller struct {
	Manifests CephManifests

	CephVersion cephv1.CephVersionSpec
	T           func() *testing.T
	// contains filtered or unexported fields
}

CephInstaller wraps installing and uninstalling rook on a platform

func NewCephInstaller added in v0.9.0 

func NewCephInstaller(t func() *testing.T, clientset *kubernetes.Clientset, useHelm bool, clusterName, rookVersion string,
	cephVersion cephv1.CephVersionSpec, cleanupHost bool) *CephInstaller

NewCephInstaller creates new instance of CephInstaller

func (*CephInstaller) CollectOperatorLog added in v1.3.9 

func (h *CephInstaller) CollectOperatorLog(suiteName, testName, namespace string)

func (*CephInstaller) CreateCephOperator added in v0.9.0 

func (h *CephInstaller) CreateCephOperator(namespace string) (err error)

CreateCephOperator creates rook-operator via kubectl

func (*CephInstaller) CreateRookCluster added in v1.3.9 

func (h *CephInstaller) CreateRookCluster(namespace, systemNamespace, storeType string, usePVC bool, storageClassName string,
	mon cephv1.MonSpec, startWithAllNodes bool, skipOSDCreation bool, cephVersion cephv1.CephVersionSpec) error

CreateRookCluster creates rook cluster via kubectl

func (*CephInstaller) CreateRookExternalCluster added in v1.3.9 

func (h *CephInstaller) CreateRookExternalCluster(namespace, firstClusterNamespace string) error

CreateRookExternalCluster creates rook external cluster via kubectl

func (*CephInstaller) CreateRookOperatorViaHelm added in v1.3.9 

func (h *CephInstaller) CreateRookOperatorViaHelm(namespace, chartSettings string) error

CreateRookOperatorViaHelm creates rook operator via Helm chart named local/rook present in local repo

func (*CephInstaller) CreateRookToolbox added in v1.3.9 

func (h *CephInstaller) CreateRookToolbox(namespace string) (err error)

CreateRookToolbox creates rook-ceph-tools via kubectl

func (*CephInstaller) Execute added in v1.3.9 

func (h *CephInstaller) Execute(command string, parameters []string, namespace string) (error, string)

Execute a command in the ceph toolbox

func (*CephInstaller) GatherAllRookLogs added in v0.9.0 

func (h *CephInstaller) GatherAllRookLogs(testName string, namespaces ...string)

func (*CephInstaller) GetCleanupPod added in v1.3.9 

func (h *CephInstaller) GetCleanupPod(node, removalDir string) string

GetCleanupPod gets a cleanup Pod that cleans up the dataDirHostPath

func (*CephInstaller) GetCleanupVerificationPod added in v1.3.9 

func (h *CephInstaller) GetCleanupVerificationPod(node, hostPathDir string) string

GetCleanupVerificationPod verifies that the dataDirHostPath is empty

func (*CephInstaller) GetDiskWipeJob added in v1.3.9 

func (h *CephInstaller) GetDiskWipeJob(nodeName, jobName, namespace string) string

GetDiskWipeJob returns a YAML manifest string for a job which will wipe clean the extra (non-boot) disks on a node, allowing Ceph to use the disk(s) during its testing.

func (*CephInstaller) GetNodeHostnames added in v0.9.0 

func (h *CephInstaller) GetNodeHostnames() ([]string, error)

GetNodeHostnames returns the list of nodes in the k8s cluster

func (*CephInstaller) GetRookExternalClusterMonConfigMap added in v1.3.9 

func (h *CephInstaller) GetRookExternalClusterMonConfigMap(namespace string) (*v1.ConfigMap, error)

GetRookExternalClusterMonConfigMap gets the monitor kubernetes configmap of the external cluster

func (*CephInstaller) GetRookExternalClusterMonSecret added in v1.3.9 

func (h *CephInstaller) GetRookExternalClusterMonSecret(namespace string) (*v1.Secret, error)

GetRookExternalClusterMonSecret gets the monitor kubernetes secret of the external cluster

func (*CephInstaller) InjectRookExternalClusterInfo added in v1.3.9 

func (h *CephInstaller) InjectRookExternalClusterInfo(namespace, firstClusterNamespace string) error

InjectRookExternalClusterInfo inject connection information for an external cluster

func (*CephInstaller) InstallRook added in v1.3.9 

func (h *CephInstaller) InstallRook(namespace, storeType string, usePVC bool, storageClassName string,
	mon cephv1.MonSpec, startWithAllNodes bool, rbdMirrorWorkers int, skipOSDCreation bool, rookVersion string) (bool, error)

InstallRook installs rook on k8s

func (*CephInstaller) UninstallRook added in v0.9.0 

func (h *CephInstaller) UninstallRook(namespace string)

UninstallRook uninstalls rook from k8s

func (*CephInstaller) UninstallRookFromMultipleNS added in v0.9.0 

func (h *CephInstaller) UninstallRookFromMultipleNS(systemNamespace string, namespaces ...string)

UninstallRookFromMultipleNS uninstalls rook from multiple namespaces in k8s

func (*CephInstaller) WipeDisks added in v1.3.9 

func (h *CephInstaller) WipeDisks(namespace string, retries int) (err error)

Wipe cluster disks

type CephManifests added in v0.9.0 

type CephManifests interface {
	GetRookCRDs() string
	GetRookOperator(namespace string) string
	GetClusterRoles(namespace, systemNamespace string) string
	GetClusterExternalRoles(namespace, systemNamespace string) string
	GetRookCluster(settings *clusterSettings) string
	GetRookExternalCluster(settings *clusterExternalSettings) string
	GetRookToolBox(namespace string) string
	GetBlockPoolDef(poolName, namespace, replicaSize string) string
	GetBlockStorageClassDef(csi bool, poolName, storageClassName, reclaimPolicy, namespace, systemNamespace string) string
	GetFileStorageClassDef(fsName, storageClassName, namespace string) string
	GetBlockPVCDef(claimName, namespace, storageClassName, accessModes, size string) string
	GetFilesystem(namepace, name string, activeCount int) string
	GetNFS(namepace, name, pool string, daemonCount int) string
	GetRBDMirror(namepace, name string, daemonCount int) string
	GetObjectStore(namespace, name string, replicaCount, port int) string
	GetObjectStoreUser(namespace, name, displayName, store string) string
	GetBucketStorageClass(namespace, storeName, storageClassName, reclaimPolicy, region string) string
	GetObc(obcName, storageClassName, bucketName string, createBucket bool) string
	GetClient(namespace, name string, caps map[string]string) string
}

func NewCephManifests added in v0.9.0 

func NewCephManifests(version string) CephManifests

NewCephManifests gets the manifest type depending on the Rook version desired

type CephManifestsMaster added in v0.9.0 

type CephManifestsMaster struct {
	// contains filtered or unexported fields
}

CephManifestsMaster wraps rook yaml definitions

func (*CephManifestsMaster) GetBlockPVCDef added in v1.3.9 

func (m *CephManifestsMaster) GetBlockPVCDef(claimName, namespace, storageClassName, accessModes, size string) string

func (*CephManifestsMaster) GetBlockPoolDef added in v0.9.0 

func (m *CephManifestsMaster) GetBlockPoolDef(poolName string, namespace string, replicaSize string) string

func (*CephManifestsMaster) GetBlockStorageClassDef added in v0.9.0 

func (m *CephManifestsMaster) GetBlockStorageClassDef(csi bool, poolName, storageClassName, reclaimPolicy, namespace, systemNamespace string) string

func (*CephManifestsMaster) GetBucketStorageClass added in v1.3.9 

func (m *CephManifestsMaster) GetBucketStorageClass(storeNameSpace string, storeName string, storageClassName string, reclaimPolicy string, region string) string

GetBucketStorageClass returns the manifest to create object bucket

func (*CephManifestsMaster) GetClient added in v1.3.9 

func (m *CephManifestsMaster) GetClient(namespace string, claimName string, caps map[string]string) string

func (*CephManifestsMaster) GetClusterExternalRoles added in v1.3.9 

func (m *CephManifestsMaster) GetClusterExternalRoles(namespace, firstClusterNamespace string) string

func (*CephManifestsMaster) GetClusterRoles added in v0.9.0 

func (m *CephManifestsMaster) GetClusterRoles(namespace, systemNamespace string) string

GetClusterRoles returns rook-cluster manifest

func (*CephManifestsMaster) GetFileStorageClassDef added in v1.3.9 

func (m *CephManifestsMaster) GetFileStorageClassDef(fsName, storageClassName, namespace string) string

func (*CephManifestsMaster) GetFilesystem added in v0.9.0 

func (m *CephManifestsMaster) GetFilesystem(namespace, name string, activeCount int) string

GetFilesystem returns the manifest to create a Rook filesystem resource with the given config.

func (*CephManifestsMaster) GetNFS added in v1.3.9 

func (m *CephManifestsMaster) GetNFS(namespace, name, pool string, count int) string

GetFilesystem returns the manifest to create a Rook Ceph NFS resource with the given config.

func (*CephManifestsMaster) GetObc added in v1.3.9 

func (m *CephManifestsMaster) GetObc(claimName string, storageClassName string, objectBucketName string, varBucketName bool) string

GetObc returns the manifest to create object bucket claim

func (*CephManifestsMaster) GetObjectStore added in v0.9.0 

func (m *CephManifestsMaster) GetObjectStore(namespace, name string, replicaCount, port int) string

func (*CephManifestsMaster) GetObjectStoreUser added in v0.9.0 

func (m *CephManifestsMaster) GetObjectStoreUser(namespace, name string, displayName string, store string) string

func (*CephManifestsMaster) GetRBDMirror added in v1.3.9 

func (m *CephManifestsMaster) GetRBDMirror(namespace, name string, count int) string

GetRBDMirror returns the manifest to create a Rook Ceph RBD Mirror resource with the given config.

func (*CephManifestsMaster) GetRookCRDs added in v0.9.0 

func (m *CephManifestsMaster) GetRookCRDs() string

func (*CephManifestsMaster) GetRookCluster added in v0.9.0 

func (m *CephManifestsMaster) GetRookCluster(settings *clusterSettings) string

GetRookCluster returns rook-cluster manifest

func (*CephManifestsMaster) GetRookExternalCluster added in v1.3.9 

func (m *CephManifestsMaster) GetRookExternalCluster(settings *clusterExternalSettings) string

func (*CephManifestsMaster) GetRookOperator added in v0.9.0 

func (m *CephManifestsMaster) GetRookOperator(namespace string) string

GetRookOperator returns rook Operator manifest

func (*CephManifestsMaster) GetRookToolBox added in v0.9.0 

func (m *CephManifestsMaster) GetRookToolBox(namespace string) string

GetRookToolBox returns rook-toolbox manifest

type CephManifestsV1_2 added in v1.3.9 

type CephManifestsV1_2 struct {
	// contains filtered or unexported fields
}

CephManifestsV1_2 wraps rook yaml definitions

func (*CephManifestsV1_2) GetBlockPVCDef added in v1.3.9 

func (m *CephManifestsV1_2) GetBlockPVCDef(claimName, namespace, storageClassName, accessModes, size string) string

func (*CephManifestsV1_2) GetBlockPoolDef added in v1.3.9 

func (m *CephManifestsV1_2) GetBlockPoolDef(poolName string, namespace string, replicaSize string) string

func (*CephManifestsV1_2) GetBlockStorageClassDef added in v1.3.9 

func (m *CephManifestsV1_2) GetBlockStorageClassDef(csi bool, poolName, storageClassName, reclaimPolicy, namespace, systemNamespace string) string

func (*CephManifestsV1_2) GetBucketStorageClass added in v1.3.9 

func (m *CephManifestsV1_2) GetBucketStorageClass(storeNameSpace string, storeName string, storageClassName string, reclaimPolicy string, region string) string

GetBucketStorageClass returns the manifest to create object bucket

func (*CephManifestsV1_2) GetClient added in v1.3.9 

func (m *CephManifestsV1_2) GetClient(namespace string, claimName string, caps map[string]string) string

func (*CephManifestsV1_2) GetClusterExternalRoles added in v1.3.9 

func (m *CephManifestsV1_2) GetClusterExternalRoles(namespace, firstClusterNamespace string) string

func (*CephManifestsV1_2) GetClusterRoles added in v1.3.9 

func (m *CephManifestsV1_2) GetClusterRoles(namespace, systemNamespace string) string

GetClusterRoles returns rook-cluster manifest

func (*CephManifestsV1_2) GetFileStorageClassDef added in v1.3.9 

func (m *CephManifestsV1_2) GetFileStorageClassDef(fsName, storageClassName, namespace string) string

func (*CephManifestsV1_2) GetFilesystem added in v1.3.9 

func (m *CephManifestsV1_2) GetFilesystem(namespace, name string, activeCount int) string

GetFilesystem returns the manifest to create a Rook filesystem resource with the given config.

func (*CephManifestsV1_2) GetNFS added in v1.3.9 

func (m *CephManifestsV1_2) GetNFS(namespace, name, pool string, count int) string

GetFilesystem returns the manifest to create a Rook Ceph NFS resource with the given config.

func (*CephManifestsV1_2) GetObc added in v1.3.9 

func (m *CephManifestsV1_2) GetObc(claimName string, storageClassName string, objectBucketName string, varBucketName bool) string

GetObc returns the manifest to create object bucket claim

func (*CephManifestsV1_2) GetObjectStore added in v1.3.9 

func (m *CephManifestsV1_2) GetObjectStore(namespace, name string, replicaCount, port int) string

func (*CephManifestsV1_2) GetObjectStoreUser added in v1.3.9 

func (m *CephManifestsV1_2) GetObjectStoreUser(namespace, name string, displayName string, store string) string

func (*CephManifestsV1_2) GetRBDMirror added in v1.3.9 

func (m *CephManifestsV1_2) GetRBDMirror(namespace, name string, count int) string

func (*CephManifestsV1_2) GetRookCRDs added in v1.3.9 

func (m *CephManifestsV1_2) GetRookCRDs() string

func (*CephManifestsV1_2) GetRookCluster added in v1.3.9 

func (m *CephManifestsV1_2) GetRookCluster(settings *clusterSettings) string

GetRookCluster returns rook-cluster manifest

func (*CephManifestsV1_2) GetRookExternalCluster added in v1.3.9 

func (m *CephManifestsV1_2) GetRookExternalCluster(settings *clusterExternalSettings) string

func (*CephManifestsV1_2) GetRookOperator added in v1.3.9 

func (m *CephManifestsV1_2) GetRookOperator(namespace string) string

GetRookOperator returns rook Operator manifest

func (*CephManifestsV1_2) GetRookToolBox added in v1.3.9 

func (m *CephManifestsV1_2) GetRookToolBox(namespace string) string

GetRookToolBox returns rook-toolbox manifest

type CockroachDBInstaller added in v0.9.0 

type CockroachDBInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewCockroachDBInstaller added in v0.9.0 

func NewCockroachDBInstaller(k8shelper *utils.K8sHelper, t func() *testing.T) *CockroachDBInstaller

func (*CockroachDBInstaller) CreateCockroachDBCluster added in v0.9.0 

func (h *CockroachDBInstaller) CreateCockroachDBCluster(namespace string, count int) error

func (*CockroachDBInstaller) CreateCockroachDBOperator added in v0.9.0 

func (h *CockroachDBInstaller) CreateCockroachDBOperator(namespace string) error

func (*CockroachDBInstaller) GatherAllCockroachDBLogs added in v0.9.0 

func (h *CockroachDBInstaller) GatherAllCockroachDBLogs(systemNamespace, namespace, testName string)

func (*CockroachDBInstaller) InstallCockroachDB added in v0.9.0 

func (h *CockroachDBInstaller) InstallCockroachDB(systemNamespace, namespace string, count int) error

func (*CockroachDBInstaller) UninstallCockroachDB added in v0.9.0 

func (h *CockroachDBInstaller) UninstallCockroachDB(systemNamespace, namespace string)

type CockroachDBManifests added in v0.9.0 

type CockroachDBManifests struct {
}

CockroachDBManifests holds the funcs which return the CockroachDB manifests

func (*CockroachDBManifests) GetCockroachDBCRDs added in v0.9.0 

func (i *CockroachDBManifests) GetCockroachDBCRDs() string

GetCockroachDBCRDs return the CockroachDB Cluster CRD

func (*CockroachDBManifests) GetCockroachDBCluster added in v0.9.0 

func (i *CockroachDBManifests) GetCockroachDBCluster(namespace string, count int) string

GetCockroachDBCluster return a CockroacDB Cluster object

func (*CockroachDBManifests) GetCockroachDBOperator added in v0.9.0 

func (i *CockroachDBManifests) GetCockroachDBOperator(namespace string) string

GetCockroachDBOperator return the CockroachDB operator manifest

type EdgefsInstaller added in v1.3.9 

type EdgefsInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewEdgefsInstaller added in v1.3.9 

func NewEdgefsInstaller(k8shelper *utils.K8sHelper, t func() *testing.T) *EdgefsInstaller

func (*EdgefsInstaller) CreateEdgefsCluster added in v1.3.9 

func (h *EdgefsInstaller) CreateEdgefsCluster(namespace string) error

func (*EdgefsInstaller) CreateEdgefsOperator added in v1.3.9 

func (h *EdgefsInstaller) CreateEdgefsOperator(systemNamespace string) error

func (*EdgefsInstaller) GatherAllEdgefsLogs added in v1.3.9 

func (h *EdgefsInstaller) GatherAllEdgefsLogs(systemNamespace, namespace, testName string)

func (*EdgefsInstaller) InstallEdgefs added in v1.3.9 

func (h *EdgefsInstaller) InstallEdgefs(systemNamespace, namespace string) error

func (*EdgefsInstaller) UninstallEdgefs added in v1.3.9 

func (h *EdgefsInstaller) UninstallEdgefs(systemNamespace, namespace string)

type EdgefsManifests added in v1.3.9 

type EdgefsManifests struct{}

func (*EdgefsManifests) GetEdgefsCRDs added in v1.3.9 

func (i *EdgefsManifests) GetEdgefsCRDs() string

func (*EdgefsManifests) GetEdgefsCluster added in v1.3.9 

func (i *EdgefsManifests) GetEdgefsCluster(namespace string) string

func (*EdgefsManifests) GetEdgefsOperator added in v1.3.9 

func (i *EdgefsManifests) GetEdgefsOperator(namespace string) string

type NFSInstaller added in v0.9.0 

type NFSInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewNFSInstaller added in v0.9.0 

func NewNFSInstaller(k8shelper *utils.K8sHelper, t func() *testing.T) *NFSInstaller

func (*NFSInstaller) CreateNFSServer added in v0.9.0 

func (h *NFSInstaller) CreateNFSServer(namespace string, count int, storageClassName string) error

CreateNFSServer creates the NFS Server CRD instance

func (*NFSInstaller) CreateNFSServerOperator added in v0.9.0 

func (h *NFSInstaller) CreateNFSServerOperator(namespace string) error

CreateNFSServerOperator creates nfs server in the provided namespace

func (*NFSInstaller) CreateNFSServerVolume added in v0.9.0 

func (h *NFSInstaller) CreateNFSServerVolume(namespace string) error

CreateNFSServerVolume creates NFS export PV and PVC

func (*NFSInstaller) GatherAllNFSServerLogs added in v0.9.0 

func (h *NFSInstaller) GatherAllNFSServerLogs(systemNamespace, namespace, testName string)

GatherAllNFSServerLogs gathers all NFS Server logs

func (*NFSInstaller) InstallNFSServer added in v0.9.0 

func (h *NFSInstaller) InstallNFSServer(systemNamespace, namespace string, count int) error

InstallNFSServer installs NFS operator, NFS CRD instance and NFS volume

func (*NFSInstaller) UninstallNFSServer added in v0.9.0 

func (h *NFSInstaller) UninstallNFSServer(systemNamespace, namespace string)

UninstallNFSServer uninstalls the NFS Server from the given namespace

type NFSManifests added in v0.9.0 

type NFSManifests struct {
}

func (*NFSManifests) GetNFSServer added in v0.9.0 

func (i *NFSManifests) GetNFSServer(namespace string, count int, storageClassName string) string

GetNFSServer returns NFSServer CRD instance definition

func (*NFSManifests) GetNFSServerCRDs added in v0.9.0 

func (i *NFSManifests) GetNFSServerCRDs() string

GetNFSServerCRDs returns NFSServer CRD definition

func (*NFSManifests) GetNFSServerOperator added in v0.9.0 

func (i *NFSManifests) GetNFSServerOperator(namespace string) string

GetNFSServerOperator returns the NFSServer operator definition

func (*NFSManifests) GetNFSServerPV added in v0.9.0 

func (i *NFSManifests) GetNFSServerPV(namespace string, clusterIP string) string

GetNFSServerPV returns NFSServer PV definition

func (*NFSManifests) GetNFSServerPVC added in v0.9.0 

func (i *NFSManifests) GetNFSServerPVC(namespace string) string

GetNFSServerPVC returns NFSServer PVC definition

type TestSuite added in v0.9.0 

type TestSuite interface {
	Setup()
	Teardown()
}

type YugabyteDBInstaller added in v1.3.9 

type YugabyteDBInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewYugabyteDBInstaller added in v1.3.9 

func NewYugabyteDBInstaller(t func() *testing.T, k8shelper *utils.K8sHelper) *YugabyteDBInstaller

func (*YugabyteDBInstaller) CreateOperator added in v1.3.9 

func (y *YugabyteDBInstaller) CreateOperator(SystemNamespace string) error

func (*YugabyteDBInstaller) CreateYugabyteDBCluster added in v1.3.9 

func (y *YugabyteDBInstaller) CreateYugabyteDBCluster(namespace string, replicaCount int) error

func (*YugabyteDBInstaller) GatherAllLogs added in v1.3.9 

func (y *YugabyteDBInstaller) GatherAllLogs(systemNS, namespace, testName string)

func (*YugabyteDBInstaller) InstallYugabyteDB added in v1.3.9 

func (y *YugabyteDBInstaller) InstallYugabyteDB(systemNS, ns string, count int) error

func (*YugabyteDBInstaller) RemoveAllYugabyteDBResources added in v1.3.9 

func (y *YugabyteDBInstaller) RemoveAllYugabyteDBResources(systemNS, namespace string) error

type YugabyteDBManifests added in v1.3.9 

type YugabyteDBManifests struct {
}

func (*YugabyteDBManifests) GetYugabyteDBCRDSpecs added in v1.3.9 

func (_ *YugabyteDBManifests) GetYugabyteDBCRDSpecs() string

func (*YugabyteDBManifests) GetYugabyteDBClusterSpecs added in v1.3.9 

func (_ *YugabyteDBManifests) GetYugabyteDBClusterSpecs(namespace string, replicaCount int) string

func (*YugabyteDBManifests) GetYugabyteDBOperatorSpecs added in v1.3.9 

func (_ *YugabyteDBManifests) GetYugabyteDBOperatorSpecs(namespace string) string

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.