deploymanager

Documentation

Index

• Constants
• Variables
• type DeployManager
  • func NewDeployManager() (*DeployManager, error)
  • func (t *DeployManager) AddCustomStorageClassName(customSCNames map[string]string) error
  • func (t *DeployManager) ArbiterEnabled() bool
  • func (t *DeployManager) CreateNamespace(namespace string) error
  • func (t *DeployManager) DefaultStorageCluster() (*ocsv1.StorageCluster, error)
  • func (t *DeployManager) DeleteNamespaceAndWait(namespace string) error
  • func (t *DeployManager) DeleteStorageCluster() error
  • func (t *DeployManager) DeleteStorageClusterAndWait(namespace string) error
  • func (t *DeployManager) DeployOCSWithOLM(ocsCatalogImage string, subscriptionChannel string) error
  • func (t *DeployManager) DumpYAML(ocsCatalogImage string, subscriptionChannel string) string
  • func (t *DeployManager) EnableArbiter()
  • func (t *DeployManager) GetArbiterZone() string
  • func (t *DeployManager) GetCsv() (v1alpha1.ClusterServiceVersion, error)
  • func (t *DeployManager) GetDeploymentImage(name string) (string, error)
  • func (t *DeployManager) GetNamespace() string
  • func (t *DeployManager) GetStorageClasses() (map[string]bool, error)
  • func (t *DeployManager) RemoveAllFinalizers(namespace string) error
  • func (t *DeployManager) SetNamespace(namespace string)
  • func (t *DeployManager) StartDefaultStorageCluster() error
  • func (t *DeployManager) UninstallOCS(ocsCatalogImage string, subscriptionChannel string) error
  • func (t *DeployManager) UpgradeOCSWithOLM(ocsCatalogImage string, subscriptionChannel string) error
  • func (t *DeployManager) VerifyComponentOperators() error
  • func (t *DeployManager) VerifyStorageClassesExist(oldSC map[string]bool) (bool, error)
  • func (t *DeployManager) WaitForCsvUpgrade(csvName string, subscriptionChannel string) error
  • func (t *DeployManager) WaitForJobSucceeded(job *batchv1.Job, namespace string) error
  • func (t *DeployManager) WaitForOCSOperator() error
  • func (t *DeployManager) WaitForPVCBound(pvc *k8sv1.PersistentVolumeClaim, namespace string) error
  • func (t *DeployManager) WaitOnStorageCluster() error

Constants

const DefaultStorageClassRBD = DefaultStorageClusterName + "-ceph-rbd"

DefaultStorageClassRBD is the name of the ceph rbd storage class the test suite installs

const DefaultStorageClusterName = "test-storagecluster"

DefaultStorageClusterName is the name of the storage cluster the test suite installs

const DefaultStorageClusterStorageSystemName = "test-storage-system"

DefaultStorageClusterStorageSystemName is the name of the storage system owned by default storage cluster

Variables

var InstallNamespace string

InstallNamespace is the namespace ocs is installed into

Types

type DeployManager

type DeployManager struct {
	Client client.Client
	// contains filtered or unexported fields
}

DeployManager is a util tool used by the functional tests

func NewDeployManager

func NewDeployManager() (*DeployManager, error)

NewDeployManager creates a DeployManager struct with default configuration

func (*DeployManager) AddCustomStorageClassName

func (t *DeployManager) AddCustomStorageClassName(customSCNames map[string]string) error

func (*DeployManager) ArbiterEnabled

func (t *DeployManager) ArbiterEnabled() bool

ArbiterEnabled returns true if the arbiter configuration is enabled in the deploy manager

func (*DeployManager) CreateNamespace

func (t *DeployManager) CreateNamespace(namespace string) error

CreateNamespace creates a namespace in the cluster, ignoring if it already exists

func (*DeployManager) DefaultStorageCluster

func (t *DeployManager) DefaultStorageCluster() (*ocsv1.StorageCluster, error)

DefaultStorageCluster returns a default StorageCluster manifest

func (*DeployManager) DeleteNamespaceAndWait

func (t *DeployManager) DeleteNamespaceAndWait(namespace string) error

DeleteNamespaceAndWait deletes a namespace and waits on it to terminate

func (*DeployManager) DeleteStorageCluster

func (t *DeployManager) DeleteStorageCluster() error

func (*DeployManager) DeleteStorageClusterAndWait

func (t *DeployManager) DeleteStorageClusterAndWait(namespace string) error

DeleteStorageClusterAndWait deletes a storageClusterCR and waits on it to terminate

func (*DeployManager) DeployOCSWithOLM

func (t *DeployManager) DeployOCSWithOLM(ocsCatalogImage string, subscriptionChannel string) error

DeployOCSWithOLM deploys ocs operator via an olm subscription

func (*DeployManager) DumpYAML

func (t *DeployManager) DumpYAML(ocsCatalogImage string, subscriptionChannel string) string

DumpYAML dumps ocs deployment yaml

func (*DeployManager) EnableArbiter

func (t *DeployManager) EnableArbiter()

EnableArbiter sets the arbiter configuration to true in the deploy manager. The arbiter zone is automatically determied at the time of cluster deploy.

func (*DeployManager) GetArbiterZone

func (t *DeployManager) GetArbiterZone() string

GetArbiterZone returns the elected arbiter zone.

func (*DeployManager) GetCsv

func (t *DeployManager) GetCsv() (v1alpha1.ClusterServiceVersion, error)

GetCsv retrieves the csv named ocs-operator

func (*DeployManager) GetDeploymentImage

func (t *DeployManager) GetDeploymentImage(name string) (string, error)

GetDeploymentImage returns the deployment image name for the deployment

func (*DeployManager) GetNamespace

func (t *DeployManager) GetNamespace() string

GetNamespace is the function used to retrieve the installation namespace

func (*DeployManager) GetStorageClasses

func (t *DeployManager) GetStorageClasses() (map[string]bool, error)

func (*DeployManager) RemoveAllFinalizers

func (t *DeployManager) RemoveAllFinalizers(namespace string) error

RemoveAllFinalizers removes all finalizers from every object in the target namespace

func (*DeployManager) SetNamespace

func (t *DeployManager) SetNamespace(namespace string)

SetNamespace is the function used to set the installation namespace

func (*DeployManager) StartDefaultStorageCluster

func (t *DeployManager) StartDefaultStorageCluster() error

StartDefaultStorageCluster creates and waits on a StorageCluster to come online

func (*DeployManager) UninstallOCS

func (t *DeployManager) UninstallOCS(ocsCatalogImage string, subscriptionChannel string) error

UninstallOCS uninstalls ocs operator and storage clusters

func (*DeployManager) UpgradeOCSWithOLM

func (t *DeployManager) UpgradeOCSWithOLM(ocsCatalogImage string, subscriptionChannel string) error

UpgradeOCSWithOLM upgrades ocs operator via an olm subscription

func (*DeployManager) VerifyComponentOperators

func (t *DeployManager) VerifyComponentOperators() error

VerifyComponentOperators makes sure that deployment images matches the ones specified in the csv deployment specs

func (*DeployManager) VerifyStorageClassesExist

func (t *DeployManager) VerifyStorageClassesExist(oldSC map[string]bool) (bool, error)

func (*DeployManager) WaitForCsvUpgrade

func (t *DeployManager) WaitForCsvUpgrade(csvName string, subscriptionChannel string) error

WaitForCsvUpgrade waits for the catalogsource to come online after an upgrade

func (*DeployManager) WaitForJobSucceeded

func (t *DeployManager) WaitForJobSucceeded(job *batchv1.Job, namespace string) error

WaitForJobSucceeded waits for a Job with a given name and namespace to succeed until 200 seconds

func (*DeployManager) WaitForOCSOperator

func (t *DeployManager) WaitForOCSOperator() error

WaitForOCSOperator waits for the ocs-operator to come online

func (*DeployManager) WaitForPVCBound

func (t *DeployManager) WaitForPVCBound(pvc *k8sv1.PersistentVolumeClaim, namespace string) error

WaitForPVCBound waits for a pvc with a given name and namespace to reach BOUND phase

func (*DeployManager) WaitOnStorageCluster

func (t *DeployManager) WaitOnStorageCluster() error

WaitOnStorageCluster waits for storage cluster to come online