Documentation
¶
Index ¶
- Constants
- func CSIDriverResourceTest(t *testing.T, driverName string)
- func ClusterStatusCheck(t *testing.T, status storageos.StorageOSClusterStatus, nodes int)
- func DeployCluster(t *testing.T, ctx *framework.TestCtx, cluster *storageos.StorageOSCluster) error
- func DeployNFSServer(t *testing.T, ctx *framework.TestCtx, nfsServer *storageos.NFSServer) error
- func NFSServerTest(t *testing.T, ctx *framework.TestCtx)
- func NewNFSServer(namespace string, nfsServerSpec storageos.NFSServerSpec) *storageos.NFSServer
- func NewStorageOSCluster(namespace string, clusterSpec storageos.StorageOSClusterSpec) *storageos.StorageOSCluster
- func NodeLabelSyncTest(t *testing.T, kubeclient kubernetes.Interface)
- func PodSchedulerAdmissionControllerTest(t *testing.T, ctx *framework.TestCtx)
- func SetupOperator(t *testing.T, ctx *framework.TestCtx)
- func StorageOSClusterCRAttributesTest(t *testing.T, crName string, crNamespace string)
- func WaitForDaemonSet(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) error
- func WaitForStatefulSet(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, ...) error
Constants ¶
const ( RetryInterval = time.Second * 5 Timeout = time.Second * 90 CleanupRetryInterval = time.Second * 1 CleanupTimeout = time.Second * 15 )
Time constants.
const TestClusterCRName string = "example-storageos"
TestClusterCRName is the name of StorageOSCluster CR used in the tests.
Variables ¶
This section is empty.
Functions ¶
func CSIDriverResourceTest ¶
CSIDriverResourceTest checks if the CSIDriver resource is created. In k8s 1.14+, CSIDriver is created as part of the cluster deployment.
func ClusterStatusCheck ¶
func ClusterStatusCheck(t *testing.T, status storageos.StorageOSClusterStatus, nodes int)
ClusterStatusCheck checks the values of cluster status based on a given number of nodes.
func DeployCluster ¶
DeployCluster creates a custom resource and checks if the storageos daemonset is deployed successfully.
func DeployNFSServer ¶
DeployNFSServer creates a custom resource and checks if the NFS Server statefulset is deployed successfully.
func NFSServerTest ¶
NFSServerTest creates a new NFSServer resource and checks if the resource is created and ready.
func NewNFSServer ¶
func NewNFSServer(namespace string, nfsServerSpec storageos.NFSServerSpec) *storageos.NFSServer
NewNFSServer returns a NFSServer object, created using a given NFS server spec.
func NewStorageOSCluster ¶
func NewStorageOSCluster(namespace string, clusterSpec storageos.StorageOSClusterSpec) *storageos.StorageOSCluster
NewStorageOSCluster returns a StorageOSCluster object, created using a given cluster spec.
func NodeLabelSyncTest ¶
func NodeLabelSyncTest(t *testing.T, kubeclient kubernetes.Interface)
NodeLabelSyncTest adds a new label to k8s node and checks if the label is synced to the storageos node labels.
func PodSchedulerAdmissionControllerTest ¶
PodSchedulerAdmissionControllerTest checks if the pod scheduler mutating admission controller mutates the scheduler name of a pod by creates a pvc backed by StorageOS and a pod that uses the PVC. NOTE: This test has a minimum k8s version requirement.
func SetupOperator ¶
SetupOperator installs the operator and ensures that the deployment is successful.
func StorageOSClusterCRAttributesTest ¶
StorageOSClusterCRAttributesTest fetches a StorageOSCluster CR object and checks if the CR properties are unset.
func WaitForDaemonSet ¶ added in v0.0.8
func WaitForDaemonSet(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, retryInterval, timeout time.Duration) error
WaitForDaemonSet checks and waits for a given daemonset to be in ready.
func WaitForStatefulSet ¶ added in v0.0.8
func WaitForStatefulSet(t *testing.T, kubeclient kubernetes.Interface, namespace, name string, retryInterval, timeout time.Duration) error
WaitForStatefulSet checks and waits for a given statefulset to be in ready.
Types ¶
This section is empty.
Source Files