installer

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: May 2, 2019 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Version tag for the latest manifests
	VersionMaster = "master"
	// Version tag for Rook v0.9
	Version0_9 = "v0.9.3"
)

Variables

View Source 
var (
	LuminousVersion = cephv1.CephVersionSpec{Image: luminousTestImage}
	MimicVersion    = cephv1.CephVersionSpec{Image: mimicTestImage}
	NautilusVersion = cephv1.CephVersionSpec{Image: nautilusTestImage}
)

Functions

func GatherCRDObjectDebuggingInfo added in v0.9.0 

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

GatherCRDObjectDebuggingInfo gathers all the descriptions for pods, pvs and pvcs

func InstallHostPathProvisioner added in v0.9.0 

func InstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

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

func IsAdditionalDeviceAvailableOnCluster added in v0.6.0 

func IsAdditionalDeviceAvailableOnCluster() bool

func SystemNamespace added in v0.6.0 

func SystemNamespace(namespace string) string

func UninstallHostPathProvisioner added in v0.9.0 

func UninstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

Types

type CassandraInstaller added in v0.9.0 

type CassandraInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewCassandraInstaller added in v0.9.0 

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

func (*CassandraInstaller) CreateCassandraCluster added in v0.9.0 

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

func (*CassandraInstaller) CreateCassandraOperator added in v0.9.0 

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

func (*CassandraInstaller) DeleteCassandraCluster added in v0.9.0 

func (ci *CassandraInstaller) DeleteCassandraCluster(namespace string)

func (*CassandraInstaller) GatherAllCassandraLogs added in v0.9.0 

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

func (*CassandraInstaller) InstallCassandra added in v0.9.0 

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

func (*CassandraInstaller) UninstallCassandra added in v0.9.0 

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

type CassandraManifests added in v0.9.0 

type CassandraManifests struct{}

func (*CassandraManifests) GetCassandraCRDs added in v0.9.0 

func (i *CassandraManifests) GetCassandraCRDs() string

func (*CassandraManifests) GetCassandraCluster added in v0.9.0 

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

func (*CassandraManifests) GetCassandraOperator added in v0.9.0 

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

type CephInstaller added in v0.9.0 

type CephInstaller struct {
	Manifests CephManifests

	CephVersion cephv1.CephVersionSpec
	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, useHelm bool, rookVersion string, cephVersion cephv1.CephVersionSpec) *CephInstaller

NewCephInstaller creates new instance of CephInstaller

func (*CephInstaller) CreateCephCRDs added in v0.9.0 

func (h *CephInstaller) CreateCephCRDs() error

func (*CephInstaller) CreateCephOperator added in v0.9.0 

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

CreateCephOperator creates rook-operator via kubectl

func (*CephInstaller) CreateK8sRookCluster added in v0.9.0 

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

func (*CephInstaller) CreateK8sRookClusterWithHostPathAndDevices added in v0.9.0 

func (h *CephInstaller) CreateK8sRookClusterWithHostPathAndDevices(namespace, systemNamespace, storeType string,
	useAllDevices bool, mon cephv1.MonSpec, startWithAllNodes bool, rbdMirrorWorkers int, cephVersion cephv1.CephVersionSpec) error

CreateK8sRookCluster creates rook cluster via kubectl

func (*CephInstaller) CreateK8sRookOperatorViaHelm added in v0.9.0 

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

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

func (*CephInstaller) CreateK8sRookToolbox added in v0.9.0 

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

CreateK8sRookToolbox creates rook-ceph-tools via kubectl

func (*CephInstaller) GatherAllRookLogs added in v0.9.0 

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

func (*CephInstaller) GetNodeHostnames added in v0.9.0 

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

func (*CephInstaller) InstallRookOnK8sWithHostPathAndDevices added in v0.9.0 

func (h *CephInstaller) InstallRookOnK8sWithHostPathAndDevices(namespace, storeType string,
	useDevices bool, mon cephv1.MonSpec, startWithAllNodes bool, rbdMirrorWorkers int) (bool, error)

InstallRookOnK8sWithHostPathAndDevices installs rook on k8s

func (*CephInstaller) UninstallRook added in v0.9.0 

func (h *CephInstaller) UninstallRook(namespace string)

UninstallRookFromK8s uninstalls rook from k8s

func (*CephInstaller) UninstallRookFromMultipleNS added in v0.9.0 

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

UninstallRookFromK8s uninstalls rook from multiple namespaces in k8s

type CephManifests added in v0.9.0 

type CephManifests interface {
	GetRookCRDs() string
	GetRookOperator(namespace string) string
	GetClusterRoles(namespace, systemNamespace string) string
	GetRookCluster(settings *ClusterSettings) string
	GetRookToolBox(namespace string) string
	GetCleanupPod(node, removalDir string) string
	GetBlockPoolDef(poolName string, namespace string, replicaSize string) string
	GetBlockStorageClassDef(poolName string, storageClassName string, reclaimPolicy string, namespace string, varClusterName bool) string
	GetBlockPvcDef(claimName string, storageClassName string, accessModes string) string
	GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, reclaimPolicy string, blockName string, accessMode string) string
	GetBlockPoolStorageClass(namespace string, poolName string, storageClassName string, reclaimPolicy string) string
	GetFilesystem(namepace, name string, activeCount int) string
	GetNFS(namepace, name, pool string, daemonCount int) string
	GetObjectStore(namespace, name string, replicaCount, port int) string
	GetObjectStoreUser(namespace, name string, displayName string, store string) string
}

func NewCephManifests added in v0.9.0 

func NewCephManifests(version string) 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) GetBlockPoolDef added in v0.9.0 

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

func (*CephManifestsMaster) GetBlockPoolStorageClass added in v0.9.0 

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

func (*CephManifestsMaster) GetBlockPoolStorageClassAndPvcDef added in v0.9.0 

func (m *CephManifestsMaster) GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, reclaimPolicy string, blockName string, accessMode string) string

func (*CephManifestsMaster) GetBlockPvcDef added in v0.9.0 

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

func (*CephManifestsMaster) GetBlockStorageClassDef added in v0.9.0 

func (m *CephManifestsMaster) GetBlockStorageClassDef(poolName string, storageClassName string, reclaimPolicy string, namespace string, varClusterName bool) string

func (*CephManifestsMaster) GetCleanupPod added in v0.9.0 

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

GetCleanupPod gets a cleanup Pod manifest

func (*CephManifestsMaster) GetClusterRoles added in v0.9.0 

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

GetClusterRoles returns rook-cluster manifest

func (*CephManifestsMaster) GetFilesystem added in v0.9.0 

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

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

func (*CephManifestsMaster) GetNFS added in v1.0.0 

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

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

func (*CephManifestsMaster) GetObjectStore added in v0.9.0 

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

func (*CephManifestsMaster) GetObjectStoreUser added in v0.9.0 

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

func (*CephManifestsMaster) GetRookCRDs added in v0.9.0 

func (m *CephManifestsMaster) GetRookCRDs() string

func (*CephManifestsMaster) GetRookCluster added in v0.9.0 

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

GetRookCluster returns rook-cluster manifest

func (*CephManifestsMaster) GetRookOperator added in v0.9.0 

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

GetRookOperator returns rook Operator manifest

func (*CephManifestsMaster) GetRookToolBox added in v0.9.0 

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

GetRookToolBox returns rook-toolbox manifest

type CephManifestsV0_9 added in v1.0.0 

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

CephManifestsV0_9 wraps rook yaml definitions

func (*CephManifestsV0_9) GetBlockPoolDef added in v1.0.0 

func (m *CephManifestsV0_9) GetBlockPoolDef(poolName string, namespace string, replicaSize string) string

func (*CephManifestsV0_9) GetBlockPoolStorageClass added in v1.0.0 

func (m *CephManifestsV0_9) GetBlockPoolStorageClass(namespace string, poolName string, storageClassName string, reclaimPolicy string) string

func (*CephManifestsV0_9) GetBlockPoolStorageClassAndPvcDef added in v1.0.0 

func (m *CephManifestsV0_9) GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, reclaimPolicy string, blockName string, accessMode string) string

func (*CephManifestsV0_9) GetBlockPvcDef added in v1.0.0 

func (m *CephManifestsV0_9) GetBlockPvcDef(claimName string, storageClassName string, accessModes string) string

func (*CephManifestsV0_9) GetBlockStorageClassDef added in v1.0.0 

func (m *CephManifestsV0_9) GetBlockStorageClassDef(poolName string, storageClassName string, reclaimPolicy string, namespace string, varClusterName bool) string

func (*CephManifestsV0_9) GetCleanupPod added in v1.0.0 

func (m *CephManifestsV0_9) GetCleanupPod(node, removalDir string) string

GetCleanupPod gets a cleanup Pod manifest

func (*CephManifestsV0_9) GetClusterRoles added in v1.0.0 

func (m *CephManifestsV0_9) GetClusterRoles(namespace, systemNamespace string) string

GetClusterRoles returns rook-cluster manifest

func (*CephManifestsV0_9) GetFilesystem added in v1.0.0 

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

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

func (*CephManifestsV0_9) GetNFS added in v1.0.0 

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

func (*CephManifestsV0_9) GetObjectStore added in v1.0.0 

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

func (*CephManifestsV0_9) GetObjectStoreUser added in v1.0.0 

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

func (*CephManifestsV0_9) GetRookCRDs added in v1.0.0 

func (m *CephManifestsV0_9) GetRookCRDs() string

func (*CephManifestsV0_9) GetRookCluster added in v1.0.0 

func (m *CephManifestsV0_9) GetRookCluster(settings *ClusterSettings) string

GetRookCluster returns rook-cluster manifest

func (*CephManifestsV0_9) GetRookOperator added in v1.0.0 

func (m *CephManifestsV0_9) GetRookOperator(namespace string) string

GetRookOperator returns rook Operator manifest

func (*CephManifestsV0_9) GetRookToolBox added in v1.0.0 

func (m *CephManifestsV0_9) GetRookToolBox(namespace string) string

GetRookToolBox returns rook-toolbox manifest

type ClusterSettings added in v0.9.0 

type ClusterSettings struct {
	Namespace        string
	StoreType        string
	DataDirHostPath  string
	UseAllDevices    bool
	Mons             int
	RBDMirrorWorkers int
	CephVersion      cephv1.CephVersionSpec
}

type CockroachDBInstaller added in v0.9.0 

type CockroachDBInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewCockroachDBInstaller added in v0.9.0 

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

func (*CockroachDBInstaller) CreateCockroachDBCluster added in v0.9.0 

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

func (*CockroachDBInstaller) CreateCockroachDBOperator added in v0.9.0 

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

func (*CockroachDBInstaller) GatherAllCockroachDBLogs added in v0.9.0 

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

func (*CockroachDBInstaller) InstallCockroachDB added in v0.9.0 

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

func (*CockroachDBInstaller) UninstallCockroachDB added in v0.9.0 

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

type CockroachDBManifests added in v0.9.0 

type CockroachDBManifests struct {
}

CockroachDBManifests holds the funcs which return the CockroachDB manifests

func (*CockroachDBManifests) GetCockroachDBCRDs added in v0.9.0 

func (i *CockroachDBManifests) GetCockroachDBCRDs() string

GetCockroachDBCRDs return the CockroachDB Cluster CRD

func (*CockroachDBManifests) GetCockroachDBCluster added in v0.9.0 

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

GetCockroachDBCluster return a CockroacDB Cluster object

func (*CockroachDBManifests) GetCockroachDBOperator added in v0.9.0 

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

GetCockroachDBOperator return the CockroachDB operator manifest

type EdgefsInstaller added in v1.0.0 

type EdgefsInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewEdgefsInstaller added in v1.0.0 

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

func (*EdgefsInstaller) CreateEdgefsCluster added in v1.0.0 

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

func (*EdgefsInstaller) CreateEdgefsOperator added in v1.0.0 

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

func (*EdgefsInstaller) GatherAllEdgefsLogs added in v1.0.0 

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

func (*EdgefsInstaller) InstallEdgefs added in v1.0.0 

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

func (*EdgefsInstaller) UninstallEdgefs added in v1.0.0 

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

type EdgefsManifests added in v1.0.0 

type EdgefsManifests struct{}

func (*EdgefsManifests) GetEdgefsCRDs added in v1.0.0 

func (i *EdgefsManifests) GetEdgefsCRDs() string

func (*EdgefsManifests) GetEdgefsCluster added in v1.0.0 

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

func (*EdgefsManifests) GetEdgefsOperator added in v1.0.0 

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

type EnvironmentManifest added in v0.9.0 

type EnvironmentManifest struct {
	HostType           string
	Helm               string
	RookImageName      string
	ToolboxImageName   string
	SkipInstallRook    bool
	LoadVolumeNumber   int
	LoadConcurrentRuns int
	LoadTime           int
	LoadSize           string
	EnableChaos        bool
}

EnvironmentManifest contains information about system under test 

var Env EnvironmentManifest

type NFSInstaller added in v0.9.0 

type NFSInstaller struct {
	T func() *testing.T
	// contains filtered or unexported fields
}

func NewNFSInstaller added in v0.9.0 

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

func (*NFSInstaller) CreateNFSServer added in v0.9.0 

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

CreateNFSServer creates the NFS Server CRD instance

func (*NFSInstaller) CreateNFSServerOperator added in v0.9.0 

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

CreateNFSServerOperator creates nfs server in the provided namespace

func (*NFSInstaller) CreateNFSServerVolume added in v0.9.0 

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

CreateNFSServerVolume creates NFS export PV and PVC

func (*NFSInstaller) GatherAllNFSServerLogs added in v0.9.0 

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

GatherAllNFSServerLogs gathers all NFS Server logs

func (*NFSInstaller) InstallNFSServer added in v0.9.0 

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

InstallNFSServer installs NFS operator, NFS CRD instance and NFS volume

func (*NFSInstaller) UninstallNFSServer added in v0.9.0 

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

UninstallNFSServer uninstalls the NFS Server from the given namespace

type NFSManifests added in v0.9.0 

type NFSManifests struct {
}

func (*NFSManifests) GetNFSServer added in v0.9.0 

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

GetNFSServer returns NFSServer CRD instance definition

func (*NFSManifests) GetNFSServerCRDs added in v0.9.0 

func (i *NFSManifests) GetNFSServerCRDs() string

GetNFSServerCRDs returns NFSServer CRD definition

func (*NFSManifests) GetNFSServerOperator added in v0.9.0 

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

GetNFSServerOperator returns the NFSServer operator definition

func (*NFSManifests) GetNFSServerPV added in v0.9.0 

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

GetNFSServerPV returns NFSServer PV definition

func (*NFSManifests) GetNFSServerPVC added in v0.9.0 

func (i *NFSManifests) GetNFSServerPVC(namespace string) string

GetNFSServerPVC returns NFSServer PVC definition

type TestSuite added in v0.9.0 

type TestSuite interface {
	Setup()
	Teardown()
}

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.