installer

Jul 17, 2020

Changes in this version

+ const CRDFullyQualifiedName

+ const CRDFullyQualifiedNameSingular

+ const CassandraTestSuite

+ const CephTestSuite

+ const CockroachDBTestSuite

+ const EdgeFSTestSuite

+ const NFSTestSuite

+ const Version1_2

+ const Version1_3

+ const YugabyteDBTestSuite

+ var MasterVersion = cephv1.CephVersionSpec

+ var NautilusVersion = cephv1.CephVersionSpec

+ var OctopusVersion = cephv1.CephVersionSpec

+ func SkipTestSuite(name string) bool

+ func TestIsOfficialBuild() bool

+ func TestLogCollectionLevel() string

+ func TestScratchDevice() string

type CephInstaller

+ CephVersion cephv1.CephVersionSpec

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

+ func (h *CephInstaller) CreateRookCluster(namespace, systemNamespace, storeType string, usePVC bool, ...) error

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

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

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

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

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

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

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

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

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

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

+ func (h *CephInstaller) InstallRook(namespace, storeType string, usePVC bool, storageClassName string, ...) (bool, error)

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

type CephManifests

+ GetBlockPVCDef func(claimName, namespace, storageClassName, accessModes, size string) string

+ GetBucketStorageClass func(namespace, storeName, storageClassName, reclaimPolicy, region string) string

+ GetClient func(namespace, name string, caps map[string]string) string

+ GetClusterExternalRoles func(namespace, systemNamespace string) string

+ GetFileStorageClassDef func(fsName, storageClassName, namespace string) string

+ GetNFS func(namepace, name, pool string, daemonCount int) string

+ GetObc func(obcName, storageClassName, bucketName string, createBucket bool) string

+ GetRBDMirror func(namepace, name string, daemonCount int) string

+ GetRookExternalCluster func(settings *clusterExternalSettings) string

type CephManifestsMaster

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

+ func (m *CephManifestsMaster) GetBucketStorageClass(storeNameSpace string, storeName string, storageClassName string, ...) string

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

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

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

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

+ func (m *CephManifestsMaster) GetObc(claimName string, storageClassName string, objectBucketName string, ...) string

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

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

+ type CephManifestsV1_2 struct

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

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

+ func (m *CephManifestsV1_2) GetBlockStorageClassDef(csi bool, ...) string

+ func (m *CephManifestsV1_2) GetBucketStorageClass(storeNameSpace string, storeName string, storageClassName string, ...) string

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

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

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

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

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

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

+ func (m *CephManifestsV1_2) GetObc(claimName string, storageClassName string, objectBucketName string, ...) string

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

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

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

+ func (m *CephManifestsV1_2) GetRookCRDs() string

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

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

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

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

+ type EdgefsInstaller struct

+ T func() *testing.T

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

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

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

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

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

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

+ type EdgefsManifests struct

+ func (i *EdgefsManifests) GetEdgefsCRDs() string

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

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

+ type YugabyteDBInstaller struct

+ T func() *testing.T

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

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

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

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

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

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

+ type YugabyteDBManifests struct

+ func (_ *YugabyteDBManifests) GetYugabyteDBCRDSpecs() string

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

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

Dec 8, 2018

Changes in this version

+ const Version0_8

+ const VersionMaster

+ var LuminousVersion = cephv1.CephVersionSpec

+ var MimicVersion = cephv1.CephVersionSpec

+ func GatherCRDObjectDebuggingInfo(k8shelper *utils.K8sHelper, namespace string)

+ func InstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

+ func UninstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

+ type CassandraInstaller struct

+ T func() *testing.T

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

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

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

+ func (ci *CassandraInstaller) DeleteCassandraCluster(namespace string)

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

+ func (ci *CassandraInstaller) InstallCassandra(systemNamespace, namespace string, count int, ...) error

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

+ type CassandraManifests struct

+ func (i *CassandraManifests) GetCassandraCRDs() string

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

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

+ type CephInstaller struct

+ Manifests CephManifests

+ T func() *testing.T

+ func NewCephInstaller(t func() *testing.T, clientset *kubernetes.Clientset, rookVersion string, ...) *CephInstaller

+ func (h *CephInstaller) CreateCephCRDs() error

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

+ func (h *CephInstaller) CreateK8sRookCluster(namespace, systemNamespace string, storeType string) (err error)

+ func (h *CephInstaller) CreateK8sRookClusterWithHostPathAndDevices(namespace, systemNamespace, storeType string, useAllDevices bool, ...) error

+ func (h *CephInstaller) CreateK8sRookOperatorViaHelm(namespace string) error

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

+ func (h *CephInstaller) GatherAllRookLogs(namespace, systemNamespace string, testName string)

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

+ func (h *CephInstaller) InstallRookOnK8sWithHostPathAndDevices(namespace, storeType string, helmInstalled, useDevices bool, ...) (bool, error)

+ func (h *CephInstaller) UninstallRook(helmInstalled bool, namespace string)

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

+ type CephManifests interface

+ GetBlockPoolDef func(poolName string, namespace string, replicaSize string) string

+ GetBlockPoolStorageClass func(namespace string, poolName string, storageClassName string, ...) string

+ GetBlockPoolStorageClassAndPvcDef func(namespace string, poolName string, storageClassName string, ...) string

+ GetBlockPvcDef func(claimName string, storageClassName string, accessModes string) string

+ GetBlockStorageClassDef func(poolName string, storageClassName string, reclaimPolicy string, ...) string

+ GetCleanupPod func(node, removalDir string) string

+ GetClusterRoles func(namespace, systemNamespace string) string

+ GetFilesystem func(namepace, name string, activeCount int) string

+ GetObjectStore func(namespace, name string, replicaCount, port int) string

+ GetObjectStoreUser func(namespace, name string, displayName string, store string) string

+ GetRookCRDs func() string

+ GetRookCluster func(settings *ClusterSettings) string

+ GetRookOperator func(namespace string) string

+ GetRookToolBox func(namespace string) string

+ func NewCephManifests(version string) CephManifests

+ type CephManifestsMaster struct

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

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

+ func (m *CephManifestsMaster) GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, ...) string

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

+ func (m *CephManifestsMaster) GetBlockStorageClassDef(poolName string, storageClassName string, reclaimPolicy string, ...) string

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

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

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

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

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

+ func (m *CephManifestsMaster) GetRookCRDs() string

+ func (m *CephManifestsMaster) GetRookCluster(settings *ClusterSettings) string

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

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

+ type CephManifestsV0_8 struct

+ func (m *CephManifestsV0_8) GetBlockPoolDef(poolName string, namespace string, replicaSize string) string

+ func (m *CephManifestsV0_8) GetBlockPoolStorageClass(namespace string, poolName string, storageClassName string, ...) string

+ func (m *CephManifestsV0_8) GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, ...) string

+ func (m *CephManifestsV0_8) GetBlockPvcDef(claimName string, storageClassName string, accessModes string) string

+ func (m *CephManifestsV0_8) GetBlockStorageClassDef(poolName string, storageClassName string, reclaimPolicy string, ...) string

+ func (m *CephManifestsV0_8) GetCleanupPod(node, removalDir string) string

+ func (m *CephManifestsV0_8) GetClusterRoles(namespace, systemNamespace string) string

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

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

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

+ func (m *CephManifestsV0_8) GetRookCRDs() string

+ func (m *CephManifestsV0_8) GetRookCluster(settings *ClusterSettings) string

+ func (m *CephManifestsV0_8) GetRookOperator(namespace string) string

+ func (m *CephManifestsV0_8) GetRookToolBox(namespace string) string

+ type ClusterSettings struct

+ CephVersion cephv1.CephVersionSpec

+ DataDirHostPath string

+ Mons int

+ Namespace string

+ RBDMirrorWorkers int

+ StoreType string

+ UseAllDevices bool

+ type CockroachDBInstaller struct

+ T func() *testing.T

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

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

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

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

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

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

+ type CockroachDBManifests struct

+ func (i *CockroachDBManifests) GetCockroachDBCRDs() string

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

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

+ type EnvironmentManifest struct

+ EnableChaos bool

+ Helm string

+ HostType string

+ LoadConcurrentRuns int

+ LoadSize string

+ LoadTime int

+ LoadVolumeNumber int

+ RookImageName string

+ SkipInstallRook bool

+ ToolboxImageName string

+ var Env EnvironmentManifest

+ type NFSInstaller struct

+ T func() *testing.T

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

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

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

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

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

+ func (h *NFSInstaller) GetNFSServerClusterIP(namespace string) (string, error)

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

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

+ type NFSManifests struct

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

+ func (i *NFSManifests) GetNFSServerCRDs() string

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

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

+ func (i *NFSManifests) GetNFSServerPVC() string

+ type TestSuite interface

+ Setup func()

+ Teardown func()

Jul 18, 2018

Changes in this version

+ func GatherCockroachDBDebuggingInfo(k8shelper *utils.K8sHelper, namespace string)

type InstallData

+ func (i *InstallData) GetCleanupPod(node, removalDir string) string

+ func (i *InstallData) GetClusterRoles(namespace, systemNamespace string) string

+ func (i *InstallData) GetCockroachDBCRDs() string

+ func (i *InstallData) GetCockroachDBCluster(namespace string, count int) string

+ func (i *InstallData) GetCockroachDBOperator(namespace string) string

+ func (i *InstallData) GetRookCRDs() string

type InstallHelper

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

+ func (h *InstallHelper) CreateCockroachDBOperator(namespace string) error

+ func (h *InstallHelper) CreateK8sRookResources() (err error)

+ func (h *InstallHelper) GatherAllCockroachDBLogs(systemNamespace, namespace, testName string)

+ func (h *InstallHelper) GetNodeHostnames() ([]string, error)

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

+ func (h *InstallHelper) InstallHostPathProvisioner() error

+ func (h *InstallHelper) UninstallCockroachDB(systemNamespace, namespace string)

+ func (h *InstallHelper) UninstallHostPathProvisioner() error

Feb 21, 2018

Changes in this version

+ func GetBlockPoolStorageClass(namespace string, poolName string, storageClassName string) string

type InstallHelper

+ func (h *InstallHelper) GatherAllRookLogs(nameSpace string, testName string)

+ func (h *InstallHelper) UninstallRook(helmInstalled bool, namespace string)

+ func (h *InstallHelper) UninstallRookFromMultipleNS(helmInstalled bool, systemNamespace string, namespaces ...string)

Nov 8, 2017

Changes in this version

+ func BlockResourceOperation(k8sh *utils.K8sHelper, yaml string, action string) (string, error)

+ func GetBlockPoolDef(poolName string, namespace string, replicaSize string) string

+ func GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, blockName string) string

+ func GetBlockPvcDef(claimName string, storageClassName string) string

+ func GetBlockStorageClassDef(poolName string, storageClassName string, namespace string) string

+ func IsAdditionalDeviceAvailableOnCluster() bool

+ func SystemNamespace(namespace string) string

type InstallData

+ func (i *InstallData) GetRookCluster(namespace, storeType, dataDirHostPath string, useAllDevices bool, mons int) string

+ func (i *InstallData) GetRookOperator(namespace string) string

+ func (i *InstallData) GetRookToolBox(namespace string) string

type InstallHelper

+ T func() *testing.T

+ func (h *InstallHelper) CleanupCluster(clusterName string)

+ func (h *InstallHelper) CreateK8sRookCluster(namespace string, storeType string) (err error)

+ func (h *InstallHelper) CreateK8sRookClusterWithHostPath(namespace string, storeType string, dataDirHostPath string, mons int) (err error)

+ func (h *InstallHelper) CreateK8sRookClusterWithHostPathAndDevices(namespace, storeType, dataDirHostPath string, useAllDevices bool, mons int) (err error)

+ func (h *InstallHelper) CreateK8sRookOperator(namespace string) (err error)

+ func (h *InstallHelper) CreateK8sRookOperatorViaHelm(namespace string) error

+ func (h *InstallHelper) CreateK8sRookToolbox(namespace string) (err error)

+ func (h *InstallHelper) InstallRookOnK8sWithHostPathAndDevices(namespace, storeType, dataDirHostPath string, useDevices bool, mons int) (bool, error)

Aug 8, 2017

Changes in this version

+ type InstallData struct

+ func NewK8sInstallData() *InstallData

+ type InstallHelper struct

+ Env objects.EnvironmentManifest

+ func NewK8sRookhelper(clientset *kubernetes.Clientset) *InstallHelper

+ func (h *InstallHelper) InstallRookOnK8s() (err error)

+ func (h *InstallHelper) UninstallRookFromK8s()