Documentation
¶
Index ¶
- Constants
- Variables
- func CreateHostPathPVs(k8shelper *utils.K8sHelper, count int, readOnly bool, pvcSize string) error
- func DeleteHostPathPVs(k8shelper *utils.K8sHelper) error
- func GetPVC(claimName, namespace, storageClassName, accessModes, size string) string
- func GetPVCClone(...) string
- func GetPVCRestore(claimName, snapshotName, namespace, storageClassName, accessModes, size string) string
- func GetPodWithVolume(podName, claimName, namespace, mountPath string, readOnly bool) string
- func GetSnapshot(snapshotName, claimName, snapshotClassName, namespace string) string
- func IsAdditionalDeviceAvailableOnCluster() bool
- func ReturnCephVersion() cephv1.CephVersionSpec
- func StorageClassName() string
- func SystemNamespace(namespace string) string
- func TestLogCollectionLevel() string
- func TestScratchDevice() string
- func UsePVC() bool
- type CephInstaller
- func (h *CephInstaller) CollectOperatorLog(suiteName, testName string)
- func (h *CephInstaller) ConfirmHelmClusterInstalledCorrectly() error
- func (h *CephInstaller) CreateBlockPoolConfiguration(values map[string]interface{}, name, scName string) error
- func (h *CephInstaller) CreateCephCluster() error
- func (h *CephInstaller) CreateCephOperator() (err error)
- func (h *CephInstaller) CreateFileSystemConfiguration(values map[string]interface{}, name, scName string) error
- func (h *CephInstaller) CreateObjectStoreConfiguration(values map[string]interface{}, name, scName string) error
- func (h *CephInstaller) CreateRookCephClusterViaHelm() error
- func (h *CephInstaller) CreateRookExternalCluster(externalManifests CephManifests) error
- func (h *CephInstaller) CreateRookOperatorViaHelm() error
- func (h *CephInstaller) CreateRookToolbox(manifests CephManifests) (err error)
- func (h *CephInstaller) CreateVolumeReplicationCRDs() (err error)
- func (h *CephInstaller) Execute(command string, parameters []string, namespace string) (error, string)
- func (h *CephInstaller) GatherAllRookLogs(testName string, namespaces ...string)
- func (h *CephInstaller) GetCleanupPod(node, removalDir string) string
- func (h *CephInstaller) GetCleanupVerificationPod(node, hostPathDir string) string
- func (h *CephInstaller) GetNodeHostnames() ([]string, error)
- func (h *CephInstaller) GetRookExternalClusterMonConfigMap() (*v1.ConfigMap, error)
- func (h *CephInstaller) GetRookExternalClusterMonSecret() (*v1.Secret, error)
- func (h *CephInstaller) InstallCSIOperator() error
- func (h *CephInstaller) InstallRook() (bool, error)
- func (h *CephInstaller) SetOperatorSetting(key, value string) error
- func (h *CephInstaller) UninstallRook()
- func (h *CephInstaller) UninstallRookFromMultipleNS(manifests ...CephManifests)
- func (h *CephInstaller) UpgradeRookCephClusterViaHelm() error
- func (h *CephInstaller) UpgradeRookOperatorViaHelm() error
- func (h *CephInstaller) WaitForToolbox(namespace string) error
- type CephManifests
- type CephManifestsMaster
- func (m *CephManifestsMaster) GetBlockPool(poolName string, replicaSize string) string
- func (m *CephManifestsMaster) GetBlockSnapshotClass(snapshotClassName, reclaimPolicy string) string
- func (m *CephManifestsMaster) GetBlockStorageClass(poolName, storageClassName, reclaimPolicy string) string
- func (m *CephManifestsMaster) GetBucketClaim(name, bucketClassName string) string
- func (m *CephManifestsMaster) GetBucketClass(name, objectStoreUserSecretName, deletionPolicy string) string
- func (m *CephManifestsMaster) GetBucketNotification(notificationName string, topicName string) string
- func (m *CephManifestsMaster) GetBucketStorageClass(storeName, storageClassName, reclaimPolicy string) string
- func (m *CephManifestsMaster) GetBucketTopic(topicName string, storeName string, httpEndpointService string) string
- func (m *CephManifestsMaster) GetCOSIDriver() string
- func (m *CephManifestsMaster) GetCRDs(k8shelper *utils.K8sHelper) string
- func (m *CephManifestsMaster) GetCSINFSRBAC() string
- func (m *CephManifestsMaster) GetCSIOperator() string
- func (m *CephManifestsMaster) GetCephCluster() string
- func (m *CephManifestsMaster) GetClient(claimName string, caps map[string]string) string
- func (m *CephManifestsMaster) GetCommon() string
- func (m *CephManifestsMaster) GetCommonExternal() string
- func (m *CephManifestsMaster) GetExternalCephCluster() string
- func (m *CephManifestsMaster) GetFileStorageClass(fsName, storageClassName string) string
- func (m *CephManifestsMaster) GetFileStorageSnapshotClass(snapshotClassName, reclaimPolicy string) string
- func (m *CephManifestsMaster) GetFilesystem(name string, activeCount int) string
- func (m *CephManifestsMaster) GetFilesystemSubvolumeGroup(fsName, groupName string) string
- func (m *CephManifestsMaster) GetNFS(name string, count int) string
- func (m *CephManifestsMaster) GetNFSPool() string
- func (m *CephManifestsMaster) GetNFSSnapshotClass(snapshotClassName, reclaimPolicy string) string
- func (m *CephManifestsMaster) GetNFSStorageClass(fsName, nfsClusterName, server, storageClassName string) string
- func (m *CephManifestsMaster) GetOBC(claimName string, storageClassName string, objectBucketName string, ...) string
- func (m *CephManifestsMaster) GetOBCNotification(claimName string, storageClassName string, objectBucketName string, ...) string
- func (m *CephManifestsMaster) GetObjectStore(name string, replicaCount, port int, tlsEnable bool, swiftAndKeystone bool) string
- func (m *CephManifestsMaster) GetObjectStoreUser(name, displayName, store, usercaps, maxsize string, maxbuckets, maxobjects int) string
- func (m *CephManifestsMaster) GetOperator() string
- func (m *CephManifestsMaster) GetRBDMirror(name string, count int) string
- func (m *CephManifestsMaster) GetToolbox() string
- func (m *CephManifestsMaster) Settings() *TestCephSettings
- type CephManifestsPreviousVersion
- func (m *CephManifestsPreviousVersion) GetBlockPool(poolName, replicaSize string) string
- func (m *CephManifestsPreviousVersion) GetBlockSnapshotClass(snapshotClassName, reclaimPolicy string) string
- func (m *CephManifestsPreviousVersion) GetBlockStorageClass(poolName, storageClassName, reclaimPolicy string) string
- func (m *CephManifestsPreviousVersion) GetBucketClaim(name, bucketClassName string) string
- func (m *CephManifestsPreviousVersion) GetBucketClass(name, objectStoreUserSecretName, deletionPolicy string) string
- func (m *CephManifestsPreviousVersion) GetBucketNotification(notificationName, topicName string) string
- func (m *CephManifestsPreviousVersion) GetBucketStorageClass(storeName, storageClassName, reclaimPolicy string) string
- func (m *CephManifestsPreviousVersion) GetBucketTopic(topicName, storeName, httpEndpointService string) string
- func (m *CephManifestsPreviousVersion) GetCOSIDriver() string
- func (m *CephManifestsPreviousVersion) GetCRDs(k8shelper *utils.K8sHelper) string
- func (m *CephManifestsPreviousVersion) GetCSINFSRBAC() string
- func (m *CephManifestsPreviousVersion) GetCSIOperator() string
- func (m *CephManifestsPreviousVersion) GetCephCluster() string
- func (m *CephManifestsPreviousVersion) GetClient(claimName string, caps map[string]string) string
- func (m *CephManifestsPreviousVersion) GetCommon() string
- func (m *CephManifestsPreviousVersion) GetCommonExternal() string
- func (m *CephManifestsPreviousVersion) GetExternalCephCluster() string
- func (m *CephManifestsPreviousVersion) GetFileStorageClass(fsName, storageClassName string) string
- func (m *CephManifestsPreviousVersion) GetFileStorageSnapshotClass(snapshotClassName, reclaimPolicy string) string
- func (m *CephManifestsPreviousVersion) GetFilesystem(name string, activeCount int) string
- func (m *CephManifestsPreviousVersion) GetFilesystemSubvolumeGroup(fsName, groupName string) string
- func (m *CephManifestsPreviousVersion) GetNFS(name string, count int) string
- func (m *CephManifestsPreviousVersion) GetNFSPool() string
- func (m *CephManifestsPreviousVersion) GetNFSSnapshotClass(fsName, snapshotClassName string) string
- func (m *CephManifestsPreviousVersion) GetNFSStorageClass(fsName, nfsClusterName, server, storageClassName string) string
- func (m *CephManifestsPreviousVersion) GetOBC(claimName, storageClassName, objectBucketName, maxObject string, ...) string
- func (m *CephManifestsPreviousVersion) GetOBCNotification(claimName, storageClassName, objectBucketName, notificationName string, ...) string
- func (m *CephManifestsPreviousVersion) GetObjectStore(name string, replicaCount, port int, tlsEnable bool, swiftAndKeystone bool) string
- func (m *CephManifestsPreviousVersion) GetObjectStoreUser(name, displayName, store, usercaps, maxsize string, maxbuckets, maxobjects int) string
- func (m *CephManifestsPreviousVersion) GetOperator() string
- func (m *CephManifestsPreviousVersion) GetRBDMirror(name string, count int) string
- func (m *CephManifestsPreviousVersion) GetToolbox() string
- func (m *CephManifestsPreviousVersion) Settings() *TestCephSettings
- type TestCephSettings
Constants ¶
const ( OperatorChartName = "rook-ceph" CephClusterChartName = "rook-ceph-cluster" )
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
const ( // LocalBuildTag tag for the latest manifests LocalBuildTag = "local-build" // test suite names CassandraTestSuite = "cassandra" CephTestSuite = "ceph" NFSTestSuite = "nfs" )
const (
// The version from which the upgrade test will start
Version1_16 = "v1.16.7"
)
Variables ¶
var ( ReefVersion = cephv1.CephVersionSpec{Image: reefTestImage} ReefDevelVersion = cephv1.CephVersionSpec{Image: reefDevelTestImage} SquidVersion = cephv1.CephVersionSpec{Image: squidTestImage} SquidDevelVersion = cephv1.CephVersionSpec{Image: squidDevelTestImage} MainVersion = cephv1.CephVersionSpec{Image: mainTestImage, AllowUnsupported: true} )
Functions ¶
func CreateHostPathPVs ¶ added in v1.6.0
************************************************************************************************ HostPath provisioner functions ************************************************************************************************
func DeleteHostPathPVs ¶ added in v1.6.0
func GetPVCClone ¶ added in v1.6.0
func GetPVCRestore ¶ added in v1.6.0
func GetPodWithVolume ¶ added in v1.6.0
func GetSnapshot ¶ added in v1.6.0
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 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
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) InstallCSIOperator ¶ added in v1.17.0
func (h *CephInstaller) InstallCSIOperator() error
func (*CephInstaller) InstallRook ¶ added in v1.3.0
func (h *CephInstaller) InstallRook() (bool, error)
func (*CephInstaller) SetOperatorSetting ¶ added in v1.17.0
func (h *CephInstaller) SetOperatorSetting(key, value string) 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
GetCSIOperator() 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, swiftAndKeystone 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
GetCOSIDriver() string
GetBucketClass(name, objectstoreUserName, deletionPolicy string) string
GetBucketClaim(claimName, className 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) GetBucketClaim ¶ added in v1.12.0
func (m *CephManifestsMaster) GetBucketClaim(name, bucketClassName string) string
func (*CephManifestsMaster) GetBucketClass ¶ added in v1.12.0
func (m *CephManifestsMaster) GetBucketClass(name, objectStoreUserSecretName, deletionPolicy 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) GetCOSIDriver ¶ added in v1.12.0
func (m *CephManifestsMaster) GetCOSIDriver() string
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) GetCSIOperator ¶ added in v1.17.0
func (m *CephManifestsMaster) GetCSIOperator() 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 (*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) GetBucketClaim ¶ added in v1.12.0
func (m *CephManifestsPreviousVersion) GetBucketClaim(name, bucketClassName string) string
func (*CephManifestsPreviousVersion) GetBucketClass ¶ added in v1.12.0
func (m *CephManifestsPreviousVersion) GetBucketClass(name, objectStoreUserSecretName, deletionPolicy 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) GetCOSIDriver ¶ added in v1.12.0
func (m *CephManifestsPreviousVersion) GetCOSIDriver() string
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) GetCSIOperator ¶ added in v1.17.0
func (m *CephManifestsPreviousVersion) GetCSIOperator() 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 (*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
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()