installer

package
v1.2.6 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2020 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Version tag for the latest manifests
	VersionMaster = "master"
	// Version tag for Rook v1.0
	Version1_0 = "v1.0.6"
	// 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 (
	MimicVersion    = cephv1.CephVersionSpec{Image: mimicTestImage}
	NautilusVersion = cephv1.CephVersionSpec{Image: nautilusTestImage}
)

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

func SkipTestSuite added in v1.1.0 

func SkipTestSuite(name string) bool

func SystemNamespace added in v0.6.0 

func SystemNamespace(namespace string) string

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, rookVersion string, cephVersion cephv1.CephVersionSpec) *CephInstaller

NewCephInstaller creates new instance of CephInstaller

func (*CephInstaller) CollectOperatorLog added in v1.1.0 

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

func (*CephInstaller) CreateCephCRDs added in v0.9.0 

func (h *CephInstaller) CreateCephCRDs() error

func (*CephInstaller) CreateCephOperator added in v0.9.0 

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

CreateCephOperator creates rook-operator via kubectl

func (*CephInstaller) CreateK8sRookClusterWithHostPathAndDevices added in v0.9.0 

func (h *CephInstaller) CreateK8sRookClusterWithHostPathAndDevices(namespace, systemNamespace, storeType string,
	mon cephv1.MonSpec, startWithAllNodes bool, rbdMirrorWorkers int, cephVersion cephv1.CephVersionSpec) error

CreateK8sRookClusterWithHostPathAndDevices creates rook cluster via kubectl

func (*CephInstaller) CreateK8sRookExternalCluster added in v1.2.3 

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

CreateK8sRookExternalCluster creates rook external cluster via kubectl

func (*CephInstaller) CreateK8sRookOperatorViaHelm added in v0.9.0 

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

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

func (*CephInstaller) CreateK8sRookToolbox added in v0.9.0 

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

CreateK8sRookToolbox creates rook-ceph-tools via kubectl

func (*CephInstaller) GatherAllRookLogs added in v0.9.0 

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

func (*CephInstaller) GetDiskWipeJob added in v1.2.0 

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.2.3 

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.2.3 

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.2.3 

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

InjectRookExternalClusterInfo inject connection information for an external cluster

func (*CephInstaller) InstallRookOnK8sWithHostPathAndDevices added in v0.9.0 

func (h *CephInstaller) InstallRookOnK8sWithHostPathAndDevices(namespace, storeType string,
	mon cephv1.MonSpec, startWithAllNodes bool, rbdMirrorWorkers int) (bool, error)

InstallRookOnK8sWithHostPathAndDevices installs rook on k8s

func (*CephInstaller) UninstallRook added in v0.9.0 

func (h *CephInstaller) UninstallRook(namespace string, gatherLogs bool)

UninstallRook uninstalls rook from k8s

func (*CephInstaller) UninstallRookFromMultipleNS added in v0.9.0 

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

UninstallRookFromMultipleNS uninstalls rook from multiple namespaces in k8s

func (*CephInstaller) WipeClusterDisks added in v1.2.0 

func (h *CephInstaller) WipeClusterDisks(namespace string) error

WipeClusterDisks runs a disk wipe job on all nodes in the k8s cluster.

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
	GetCleanupPod(node, removalDir string) string
	GetBlockPoolDef(poolName string, namespace string, replicaSize string) string
	GetBlockStorageClassDef(poolName string, storageClassName string, reclaimPolicy string, namespace string, varClusterName bool) string
	GetBlockPvcDef(claimName string, storageClassName string, accessModes string, size string) string
	GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, reclaimPolicy string, blockName string, accessMode string) string
	GetBlockPoolStorageClass(namespace string, poolName string, storageClassName string, reclaimPolicy string) string
	GetFilesystem(namepace, name string, activeCount int) string
	GetNFS(namepace, name, pool string, daemonCount int) string
	GetObjectStore(namespace, name string, replicaCount, port int) string
	GetObjectStoreUser(namespace, name string, displayName string, store string) string
	GetBucketStorageClass(namespace string, storeName string, storageClassName string, reclaimPolicy string, region string) string
	GetObc(obcName string, storageClassName string, bucketName string, createBucket bool) string
	GetClient(namespace string, 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) GetBlockPoolDef added in v0.9.0 

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

func (*CephManifestsMaster) GetBlockPoolStorageClass added in v0.9.0 

func (m *CephManifestsMaster) GetBlockPoolStorageClass(namespace string, poolName string, storageClassName string, reclaimPolicy string) string

func (*CephManifestsMaster) GetBlockPoolStorageClassAndPvcDef added in v0.9.0 

func (m *CephManifestsMaster) GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, reclaimPolicy string, blockName string, accessMode string) string

func (*CephManifestsMaster) GetBlockPvcDef added in v0.9.0 

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

func (*CephManifestsMaster) GetBlockStorageClassDef added in v0.9.0 

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

func (*CephManifestsMaster) GetBucketStorageClass added in v1.1.0 

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) GetCleanupPod added in v0.9.0 

func (m *CephManifestsMaster) GetCleanupPod(node, removalDir string) string

GetCleanupPod gets a cleanup Pod manifest

func (*CephManifestsMaster) GetClient added in v1.2.0 

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

GetClient returns the manifest to create client CRD

func (*CephManifestsMaster) GetClusterExternalRoles added in v1.2.3 

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

GetClusterExternalRoles returns rook-cluster-external manifest

func (*CephManifestsMaster) GetClusterRoles added in v0.9.0 

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

GetClusterRoles returns rook-cluster manifest

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.0.0 

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.1.0 

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

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

GetRookExternalCluster returns rook-cluster-external manifest

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_0 added in v1.1.0 

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

CephManifestsV1_0 wraps rook yaml definitions

func (*CephManifestsV1_0) GetBlockPoolDef added in v1.1.0 

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

func (*CephManifestsV1_0) GetBlockPoolStorageClass added in v1.1.0 

func (m *CephManifestsV1_0) GetBlockPoolStorageClass(namespace string, poolName string, storageClassName string, reclaimPolicy string) string

func (*CephManifestsV1_0) GetBlockPoolStorageClassAndPvcDef added in v1.1.0 

func (m *CephManifestsV1_0) GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, reclaimPolicy string, blockName string, accessMode string) string

func (*CephManifestsV1_0) GetBlockPvcDef added in v1.1.0 

func (m *CephManifestsV1_0) GetBlockPvcDef(claimName, storageClassName, accessModes, size string) string

func (*CephManifestsV1_0) GetBlockStorageClassDef added in v1.1.0 

func (m *CephManifestsV1_0) GetBlockStorageClassDef(poolName string, storageClassName string, reclaimPolicy string, namespace string, varClusterName bool) string

func (*CephManifestsV1_0) GetBucketStorageClass added in v1.1.0 

func (m *CephManifestsV1_0) GetBucketStorageClass(namespace string, storeName string, storageClassName string, reclaimPolicy string, region string) string

func (*CephManifestsV1_0) GetCleanupPod added in v1.1.0 

func (m *CephManifestsV1_0) GetCleanupPod(node, removalDir string) string

GetCleanupPod gets a cleanup Pod manifest

func (*CephManifestsV1_0) GetClient added in v1.2.0 

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

func (*CephManifestsV1_0) GetClusterExternalRoles added in v1.2.3 

func (m *CephManifestsV1_0) GetClusterExternalRoles(namespace, systemNamespace string) string

GetClusterExternalRoles get the cluster roles of an external cluster

func (*CephManifestsV1_0) GetClusterRoles added in v1.1.0 

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

GetClusterRoles returns rook-cluster manifest

func (*CephManifestsV1_0) GetFilesystem added in v1.1.0 

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

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

func (*CephManifestsV1_0) GetNFS added in v1.1.0 

func (m *CephManifestsV1_0) 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_0) GetObc added in v1.1.0 

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

func (*CephManifestsV1_0) GetObjectStore added in v1.1.0 

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

func (*CephManifestsV1_0) GetObjectStoreUser added in v1.1.0 

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

func (*CephManifestsV1_0) GetRookCRDs added in v1.1.0 

func (m *CephManifestsV1_0) GetRookCRDs() string

func (*CephManifestsV1_0) GetRookCluster added in v1.1.0 

func (m *CephManifestsV1_0) GetRookCluster(settings *ClusterSettings) string

GetRookCluster returns rook-cluster manifest

func (*CephManifestsV1_0) GetRookExternalCluster added in v1.2.3 

func (m *CephManifestsV1_0) GetRookExternalCluster(settings *ClusterExternalSettings) string

GetRookExternalCluster get an external cluster

func (*CephManifestsV1_0) GetRookOperator added in v1.1.0 

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

GetRookOperator returns rook Operator manifest

func (*CephManifestsV1_0) GetRookToolBox added in v1.1.0 

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

GetRookToolBox returns rook-toolbox manifest

type ClusterExternalSettings added in v1.2.3 

type ClusterExternalSettings struct {
	Namespace       string
	DataDirHostPath string
}

ClusterExternalSettings represents the settings of an external cluster

type ClusterSettings added in v0.9.0 

type ClusterSettings struct {
	Namespace        string
	StoreType        string
	DataDirHostPath  string
	UseAllDevices    bool
	Mons             int
	RBDMirrorWorkers int
	CephVersion      cephv1.CephVersionSpec
}

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.0.0 

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

func NewEdgefsInstaller added in v1.0.0 

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

func (*EdgefsInstaller) CreateEdgefsCluster added in v1.0.0 

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

func (*EdgefsInstaller) CreateEdgefsOperator added in v1.0.0 

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

func (*EdgefsInstaller) GatherAllEdgefsLogs added in v1.0.0 

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

func (*EdgefsInstaller) InstallEdgefs added in v1.0.0 

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

func (*EdgefsInstaller) UninstallEdgefs added in v1.0.0 

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

type EdgefsManifests added in v1.0.0 

type EdgefsManifests struct{}

func (*EdgefsManifests) GetEdgefsCRDs added in v1.0.0 

func (i *EdgefsManifests) GetEdgefsCRDs() string

func (*EdgefsManifests) GetEdgefsCluster added in v1.0.0 

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

func (*EdgefsManifests) GetEdgefsOperator added in v1.0.0 

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

type EnvironmentManifest added in v0.9.0 

type EnvironmentManifest struct {
	HostType           string
	Helm               string
	RookImageName      string
	ToolboxImageName   string
	BaseTestDir        string
	SkipInstallRook    bool
	LoadVolumeNumber   int
	LoadConcurrentRuns int
	LoadTime           int
	LoadSize           string
	EnableChaos        bool
	Logs               string
}

EnvironmentManifest contains information about system under test 

var Env EnvironmentManifest

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.1.0 

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

func NewYugabyteDBInstaller added in v1.1.0 

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

func (*YugabyteDBInstaller) CreateOperator added in v1.1.0 

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

func (*YugabyteDBInstaller) CreateYugabyteDBCluster added in v1.1.0 

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

func (*YugabyteDBInstaller) GatherAllLogs added in v1.1.0 

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

func (*YugabyteDBInstaller) InstallYugabyteDB added in v1.1.0 

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

func (*YugabyteDBInstaller) RemoveAllYugabyteDBResources added in v1.1.0 

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

type YugabyteDBManifests added in v1.1.0 

type YugabyteDBManifests struct {
}

func (*YugabyteDBManifests) GetYugabyteDBCRDSpecs added in v1.1.0 

func (_ *YugabyteDBManifests) GetYugabyteDBCRDSpecs() string

func (*YugabyteDBManifests) GetYugabyteDBClusterSpecs added in v1.1.0 

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

func (*YugabyteDBManifests) GetYugabyteDBOperatorSpecs added in v1.1.0 

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.