installer

package
v1.11.0-alpha.0 Latest Latest
Warning

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

 Go to latest Published: Feb 15, 2023 License: Apache-2.0 Imports: 30 Imported by: 18

Documentation

Index

Constants

View Source 
const (
	OperatorChartName    = "rook-ceph"
	CephClusterChartName = "rook-ceph-cluster"
)
View Source 
const (
	BlockPoolName     = "ceph-block-test"
	BlockPoolSCName   = "ceph-block-test-sc"
	FilesystemName    = "ceph-filesystem-test"
	FilesystemSCName  = "ceph-filesystem-test-sc"
	ObjectStoreName   = "ceph-objectstore-test"
	ObjectStoreSCName = "ceph-bucket-test-sc"
)

The Ceph Storage CustomResource and StorageClass names used in testing

View Source 
const (
	// LocalBuildTag tag for the latest manifests
	LocalBuildTag = "local-build"

	// test suite names
	CassandraTestSuite = "cassandra"
	CephTestSuite      = "ceph"
	NFSTestSuite       = "nfs"
)
View Source 
const (
	// The version from which the upgrade test will start
	Version1_10 = "v1.10.10"
)

Variables

View Source 
var (
	PacificVersion      = cephv1.CephVersionSpec{Image: pacificTestImage}
	PacificDevelVersion = cephv1.CephVersionSpec{Image: pacificDevelTestImage}
	QuincyVersion       = cephv1.CephVersionSpec{Image: quincyTestImage}
	QuincyDevelVersion  = cephv1.CephVersionSpec{Image: quincyDevelTestImage}
	MainVersion         = cephv1.CephVersionSpec{Image: mainTestImage, AllowUnsupported: true}
)

Functions

func CreateHostPathPVs added in v1.6.0 

func CreateHostPathPVs(k8shelper *utils.K8sHelper, count int, readOnly bool, pvcSize string) error

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

func DeleteHostPathPVs added in v1.6.0 

func DeleteHostPathPVs(k8shelper *utils.K8sHelper) error

func GetPVC added in v1.6.0 

func GetPVC(claimName, namespace, storageClassName, accessModes, size string) string

func GetPVCClone added in v1.6.0 

func GetPVCClone(cloneClaimName, parentClaimName, namespace, storageClassName, accessModes, size string) string

func GetPVCRestore added in v1.6.0 

func GetPVCRestore(claimName, snapshotName, namespace, storageClassName, accessModes, size string) string

func GetPodWithVolume added in v1.6.0 

func GetPodWithVolume(podName, claimName, namespace, mountPath string, readOnly bool) string

func GetSnapshot added in v1.6.0 

func GetSnapshot(snapshotName, claimName, snapshotClassName, namespace string) string

func IsAdditionalDeviceAvailableOnCluster added in v0.6.0 

func IsAdditionalDeviceAvailableOnCluster() bool

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

func ReturnCephVersion added in v1.8.0 

func ReturnCephVersion() cephv1.CephVersionSpec

func StorageClassName added in v1.5.0 

func StorageClassName() string

func SystemNamespace added in v0.6.0 

func SystemNamespace(namespace string) string

func TestLogCollectionLevel added in v1.4.0 

func TestLogCollectionLevel() string

TestLogCollectionLevel gets whether to collect all logs

func TestScratchDevice added in v1.4.0 

func TestScratchDevice() string

TestScratchDevice get the scratch device to be used for OSD

func UsePVC added in v1.5.0 

func UsePVC() bool

Types

type CephInstaller added in v0.9.0 

type CephInstaller struct {
	Manifests CephManifests

	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, settings *TestCephSettings) *CephInstaller

NewCephInstaller creates new instance of CephInstaller

func (*CephInstaller) CollectOperatorLog added in v1.1.0 

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

func (*CephInstaller) ConfirmHelmClusterInstalledCorrectly added in v1.7.1 

func (h *CephInstaller) ConfirmHelmClusterInstalledCorrectly() error

ConfirmHelmClusterInstalledCorrectly runs some validation to check whether the helm chart installed correctly.

func (*CephInstaller) CreateBlockPoolConfiguration added in v1.7.1 

func (h *CephInstaller) CreateBlockPoolConfiguration(values map[string]interface{}, name, scName string) error

CreateBlockPoolConfiguration creates a block store configuration

func (*CephInstaller) CreateCephCluster added in v1.6.0 

func (h *CephInstaller) CreateCephCluster() error

CreateCephCluster creates rook cluster via kubectl

func (*CephInstaller) CreateCephOperator added in v0.9.0 

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

CreateCephOperator creates rook-operator via kubectl

func (*CephInstaller) CreateFileSystemConfiguration added in v1.7.1 

func (h *CephInstaller) CreateFileSystemConfiguration(values map[string]interface{}, name, scName string) error

CreateFileSystemConfiguration creates a filesystem configuration

func (*CephInstaller) CreateObjectStoreConfiguration added in v1.7.1 

func (h *CephInstaller) CreateObjectStoreConfiguration(values map[string]interface{}, name, scName string) error

CreateObjectStoreConfiguration creates an object store configuration

func (*CephInstaller) CreateRookCephClusterViaHelm added in v1.7.1 

func (h *CephInstaller) CreateRookCephClusterViaHelm() error

CreateRookCephClusterViaHelm creates rook cluster via Helm

func (*CephInstaller) CreateRookExternalCluster added in v1.3.0 

func (h *CephInstaller) CreateRookExternalCluster(externalManifests CephManifests) error

CreateRookExternalCluster creates rook external cluster via kubectl

func (*CephInstaller) CreateRookOperatorViaHelm added in v1.3.0 

func (h *CephInstaller) CreateRookOperatorViaHelm() error

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

func (*CephInstaller) CreateRookToolbox added in v1.3.0 

func (h *CephInstaller) CreateRookToolbox(manifests CephManifests) (err error)

CreateRookToolbox creates rook-ceph-tools via kubectl

func (*CephInstaller) CreateVolumeReplicationCRDs added in v1.7.5 

func (h *CephInstaller) CreateVolumeReplicationCRDs() (err error)

func (*CephInstaller) Execute added in v1.4.0 

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

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

GetCleanupPod gets a cleanup Pod that cleans up the dataDirHostPath

func (*CephInstaller) GetCleanupVerificationPod added in v1.4.0 

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

GetCleanupVerificationPod verifies that the dataDirHostPath is empty

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() (*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() (*v1.Secret, error)

GetRookExternalClusterMonSecret gets the monitor kubernetes secret of the external cluster

func (*CephInstaller) InstallRook added in v1.3.0 

func (h *CephInstaller) InstallRook() (bool, error)

func (*CephInstaller) UninstallRook added in v0.9.0 

func (h *CephInstaller) UninstallRook()

UninstallRook uninstalls rook from k8s

func (*CephInstaller) UninstallRookFromMultipleNS added in v0.9.0 

func (h *CephInstaller) UninstallRookFromMultipleNS(manifests ...CephManifests)

UninstallRookFromMultipleNS uninstalls rook from multiple namespaces in k8s

func (*CephInstaller) UpgradeRookCephClusterViaHelm added in v1.9.0 

func (h *CephInstaller) UpgradeRookCephClusterViaHelm() error

func (*CephInstaller) UpgradeRookOperatorViaHelm added in v1.9.0 

func (h *CephInstaller) UpgradeRookOperatorViaHelm() error

func (*CephInstaller) WaitForToolbox added in v1.6.5 

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

type CephManifests added in v0.9.0 

type CephManifests interface {
	Settings() *TestCephSettings
	GetCRDs(k8shelper *utils.K8sHelper) string
	GetCSINFSRBAC() string
	GetOperator() string
	GetCommon() string
	GetCommonExternal() string
	GetCephCluster() string
	GetExternalCephCluster() string
	GetToolbox() string
	GetBlockPool(poolName, replicaSize string) string
	GetBlockStorageClass(poolName, storageClassName, reclaimPolicy string) string
	GetFileStorageClass(fsName, storageClassName string) string
	GetNFSStorageClass(fsName, nfsClusterName, server, storageClassName string) string
	GetNFSSnapshotClass(fsName, snapshotClassName string) string
	GetBlockSnapshotClass(snapshotClassName, reclaimPolicy string) string
	GetFileStorageSnapshotClass(snapshotClassName, reclaimPolicy string) string
	GetFilesystem(name string, activeCount int) string
	GetNFS(name string, daemonCount int) string
	GetNFSPool() string
	GetRBDMirror(name string, daemonCount int) string
	GetObjectStore(name string, replicaCount, port int, tlsEnable bool) string
	GetObjectStoreUser(name, displayName, store, usercaps, maxsize string, maxbuckets, maxobjects int) string
	GetBucketStorageClass(storeName, storageClassName, reclaimPolicy string) string
	GetOBC(obcName, storageClassName, bucketName string, maxObject string, createBucket bool) string
	GetOBCNotification(obcName, storageClassName, bucketName string, notificationName string, createBucket bool) string
	GetBucketNotification(notificationName string, topicName string) string
	GetBucketTopic(topicName string, storeName string, httpEndpointService string) string
	GetClient(name string, caps map[string]string) string
	GetFilesystemSubvolumeGroup(fsName, groupName string) string
}

func NewCephManifests added in v0.9.0 

func NewCephManifests(settings *TestCephSettings) 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) GetBlockPool added in v1.6.0 

func (m *CephManifestsMaster) GetBlockPool(poolName string, replicaSize string) string

func (*CephManifestsMaster) GetBlockSnapshotClass added in v1.5.0 

func (m *CephManifestsMaster) GetBlockSnapshotClass(snapshotClassName, reclaimPolicy string) string

func (*CephManifestsMaster) GetBlockStorageClass added in v1.6.0 

func (m *CephManifestsMaster) GetBlockStorageClass(poolName, storageClassName, reclaimPolicy string) string

func (*CephManifestsMaster) GetBucketNotification added in v1.8.0 

func (m *CephManifestsMaster) GetBucketNotification(notificationName string, topicName string) string

GetBucketNotification returns the manifest to create ceph bucket notification

func (*CephManifestsMaster) GetBucketStorageClass added in v1.1.0 

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

GetBucketStorageClass returns the manifest to create object bucket

func (*CephManifestsMaster) GetBucketTopic added in v1.8.0 

func (m *CephManifestsMaster) GetBucketTopic(topicName string, storeName string, httpEndpointService string) string

GetBucketTopic returns the manifest to create ceph bucket topic

func (*CephManifestsMaster) GetCRDs added in v1.6.0 

func (m *CephManifestsMaster) GetCRDs(k8shelper *utils.K8sHelper) string

func (*CephManifestsMaster) GetCSINFSRBAC added in v1.9.6 

func (m *CephManifestsMaster) GetCSINFSRBAC() string

func (*CephManifestsMaster) GetCephCluster added in v1.6.0 

func (m *CephManifestsMaster) GetCephCluster() string

func (*CephManifestsMaster) GetClient added in v1.2.0 

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

func (*CephManifestsMaster) GetCommon added in v1.6.0 

func (m *CephManifestsMaster) GetCommon() string

func (*CephManifestsMaster) GetCommonExternal added in v1.6.0 

func (m *CephManifestsMaster) GetCommonExternal() string

func (*CephManifestsMaster) GetExternalCephCluster added in v1.6.0 

func (m *CephManifestsMaster) GetExternalCephCluster() string

func (*CephManifestsMaster) GetFileStorageClass added in v1.6.0 

func (m *CephManifestsMaster) GetFileStorageClass(fsName, storageClassName string) string

func (*CephManifestsMaster) GetFileStorageSnapshotClass added in v1.5.0 

func (m *CephManifestsMaster) GetFileStorageSnapshotClass(snapshotClassName, reclaimPolicy string) string

func (*CephManifestsMaster) GetFilesystem added in v0.9.0 

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

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

func (*CephManifestsMaster) GetFilesystemSubvolumeGroup added in v1.9.6 

func (m *CephManifestsMaster) GetFilesystemSubvolumeGroup(fsName, groupName string) string

func (*CephManifestsMaster) GetNFS added in v1.0.0 

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

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

func (*CephManifestsMaster) GetNFSPool added in v1.8.1 

func (m *CephManifestsMaster) GetNFSPool() string

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

func (*CephManifestsMaster) GetNFSSnapshotClass added in v1.11.0 

func (m *CephManifestsMaster) GetNFSSnapshotClass(snapshotClassName, reclaimPolicy string) string

func (*CephManifestsMaster) GetNFSStorageClass added in v1.9.6 

func (m *CephManifestsMaster) GetNFSStorageClass(fsName, nfsClusterName, server, storageClassName string) string

func (*CephManifestsMaster) GetOBC added in v1.6.0 

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

GetOBC returns the manifest to create object bucket claim

func (*CephManifestsMaster) GetOBCNotification added in v1.8.0 

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

GetOBCNotification returns the manifest to create object bucket claim

func (*CephManifestsMaster) GetObjectStore added in v0.9.0 

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

func (*CephManifestsMaster) GetObjectStoreUser added in v0.9.0 

func (m *CephManifestsMaster) GetObjectStoreUser(name, displayName, store, usercaps, maxsize string, maxbuckets, maxobjects int) string

func (*CephManifestsMaster) GetOperator added in v1.6.0 

func (m *CephManifestsMaster) GetOperator() string

func (*CephManifestsMaster) GetRBDMirror added in v1.4.0 

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

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

func (*CephManifestsMaster) GetToolbox added in v1.6.0 

func (m *CephManifestsMaster) GetToolbox() string

func (*CephManifestsMaster) Settings added in v1.6.0 

func (m *CephManifestsMaster) Settings() *TestCephSettings

type CephManifestsPreviousVersion added in v1.8.0 

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

CephManifestsPreviousVersion wraps rook yaml definitions

func (*CephManifestsPreviousVersion) GetBlockPool added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetBlockPool(poolName, replicaSize string) string

func (*CephManifestsPreviousVersion) GetBlockSnapshotClass added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetBlockSnapshotClass(snapshotClassName, reclaimPolicy string) string

func (*CephManifestsPreviousVersion) GetBlockStorageClass added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetBlockStorageClass(poolName, storageClassName, reclaimPolicy string) string

func (*CephManifestsPreviousVersion) GetBucketNotification added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetBucketNotification(notificationName, topicName string) string

GetBucketNotification returns the manifest to create ceph bucket notification

func (*CephManifestsPreviousVersion) GetBucketStorageClass added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetBucketStorageClass(storeName, storageClassName, reclaimPolicy string) string

GetBucketStorageClass returns the manifest to create object bucket

func (*CephManifestsPreviousVersion) GetBucketTopic added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetBucketTopic(topicName, storeName, httpEndpointService string) string

GetBucketTopic returns the manifest to create ceph bucket topic

func (*CephManifestsPreviousVersion) GetCRDs added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetCRDs(k8shelper *utils.K8sHelper) string

func (*CephManifestsPreviousVersion) GetCSINFSRBAC added in v1.9.6 

func (m *CephManifestsPreviousVersion) GetCSINFSRBAC() string

func (*CephManifestsPreviousVersion) GetCephCluster added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetCephCluster() string

GetRookCluster returns rook-cluster manifest

func (*CephManifestsPreviousVersion) GetClient added in v1.8.0 

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

func (*CephManifestsPreviousVersion) GetCommon added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetCommon() string

GetCommon returns rook-cluster manifest

func (*CephManifestsPreviousVersion) GetCommonExternal added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetCommonExternal() string

func (*CephManifestsPreviousVersion) GetExternalCephCluster added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetExternalCephCluster() string

func (*CephManifestsPreviousVersion) GetFileStorageClass added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetFileStorageClass(fsName, storageClassName string) string

func (*CephManifestsPreviousVersion) GetFileStorageSnapshotClass added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetFileStorageSnapshotClass(snapshotClassName, reclaimPolicy string) string

func (*CephManifestsPreviousVersion) GetFilesystem added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetFilesystem(name string, activeCount int) string

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

func (*CephManifestsPreviousVersion) GetFilesystemSubvolumeGroup added in v1.9.6 

func (m *CephManifestsPreviousVersion) GetFilesystemSubvolumeGroup(fsName, groupName string) string

func (*CephManifestsPreviousVersion) GetNFS added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetNFS(name string, count int) string

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

func (*CephManifestsPreviousVersion) GetNFSPool added in v1.8.1 

func (m *CephManifestsPreviousVersion) GetNFSPool() string

func (*CephManifestsPreviousVersion) GetNFSSnapshotClass added in v1.11.0 

func (m *CephManifestsPreviousVersion) GetNFSSnapshotClass(fsName, snapshotClassName string) string

func (*CephManifestsPreviousVersion) GetNFSStorageClass added in v1.9.6 

func (m *CephManifestsPreviousVersion) GetNFSStorageClass(fsName, nfsClusterName, server, storageClassName string) string

func (*CephManifestsPreviousVersion) GetOBC added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetOBC(claimName, storageClassName, objectBucketName, maxObject string, varBucketName bool) string

GetOBC returns the manifest to create object bucket claim

func (*CephManifestsPreviousVersion) GetOBCNotification added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetOBCNotification(claimName, storageClassName, objectBucketName, notificationName string, varBucketName bool) string

GetOBCNotification returns the manifest to create object bucket claim

func (*CephManifestsPreviousVersion) GetObjectStore added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetObjectStore(name string, replicaCount, port int, tlsEnable bool) string

func (*CephManifestsPreviousVersion) GetObjectStoreUser added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetObjectStoreUser(name, displayName, store, usercaps, maxsize string, maxbuckets, maxobjects int) string

func (*CephManifestsPreviousVersion) GetOperator added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetOperator() string

GetRookOperator returns rook Operator manifest

func (*CephManifestsPreviousVersion) GetRBDMirror added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetRBDMirror(name string, count int) string

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

func (*CephManifestsPreviousVersion) GetToolbox added in v1.8.0 

func (m *CephManifestsPreviousVersion) GetToolbox() string

GetRookToolBox returns rook-toolbox manifest

func (*CephManifestsPreviousVersion) Settings added in v1.8.0 

func (m *CephManifestsPreviousVersion) Settings() *TestCephSettings

type TestCephSettings added in v1.6.0 

type TestCephSettings struct {
	DataDirHostPath             string
	ClusterName                 string
	Namespace                   string
	OperatorNamespace           string
	StorageClassName            string
	UseHelm                     bool
	RetainHelmDefaultStorageCRs bool
	UsePVC                      bool
	Mons                        int
	UseCrashPruner              bool
	MultipleMgrs                bool
	SkipOSDCreation             bool
	EnableDiscovery             bool
	EnableAdmissionController   bool
	IsExternal                  bool
	SkipClusterCleanup          bool
	SkipCleanupPolicy           bool
	DirectMountToolbox          bool
	ConnectionsEncrypted        bool
	ConnectionsCompressed       bool
	RequireMsgr2                bool
	EnableVolumeReplication     bool
	TestNFSCSI                  bool
	ChangeHostName              bool
	RookVersion                 string
	CephVersion                 cephv1.CephVersionSpec
	KubernetesVersion           string
}

TestCephSettings struct for handling panic and test suite tear down

func (*TestCephSettings) ApplyEnvVars added in v1.6.0 

func (s *TestCephSettings) ApplyEnvVars()

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.