installer

package
v0.0.0-...-1ea1cc7 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	// Version tag for the latest manifests
	VersionMaster = "master"
	// Version tag for Rook v0.8
	Version0_8 = "v0.8.3"
)

Variables

View Source 
var (
	LuminousVersion = cephv1.CephVersionSpec{Image: luminousTestImage, Name: cephv1.Luminous}
	MimicVersion    = cephv1.CephVersionSpec{Image: mimicTestImage, Name: cephv1.Mimic}
)

Functions

func GatherCRDObjectDebuggingInfo 

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

GatherCRDObjectDebuggingInfo gathers all the descriptions for pods, pvs and pvcs

func InstallHostPathProvisioner 

func InstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

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

func IsAdditionalDeviceAvailableOnCluster 

func IsAdditionalDeviceAvailableOnCluster() bool

func SystemNamespace 

func SystemNamespace(namespace string) string

func UninstallHostPathProvisioner 

func UninstallHostPathProvisioner(k8shelper *utils.K8sHelper) error

Types

type CassandraInstaller 

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

func NewCassandraInstaller 

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

func (*CassandraInstaller) CreateCassandraCluster 

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

func (*CassandraInstaller) CreateCassandraOperator 

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

func (*CassandraInstaller) DeleteCassandraCluster 

func (ci *CassandraInstaller) DeleteCassandraCluster(namespace string)

func (*CassandraInstaller) GatherAllCassandraLogs 

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

func (*CassandraInstaller) InstallCassandra 

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

func (*CassandraInstaller) UninstallCassandra 

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

type CassandraManifests 

type CassandraManifests struct{}

func (*CassandraManifests) GetCassandraCRDs 

func (i *CassandraManifests) GetCassandraCRDs() string

func (*CassandraManifests) GetCassandraCluster 

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

func (*CassandraManifests) GetCassandraOperator 

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

type CephInstaller 

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 

func NewCephInstaller(t func() *testing.T, clientset *kubernetes.Clientset, rookVersion string, cephVersion cephv1.CephVersionSpec) *CephInstaller

NewCephInstaller creates new instance of CephInstaller

func (*CephInstaller) CreateCephCRDs 

func (h *CephInstaller) CreateCephCRDs() error

func (*CephInstaller) CreateCephOperator 

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

CreateCephOperator creates rook-operator via kubectl

func (*CephInstaller) CreateK8sRookCluster 

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

func (*CephInstaller) CreateK8sRookClusterWithHostPathAndDevices 

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 

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

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

func (*CephInstaller) CreateK8sRookToolbox 

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

CreateK8sRookToolbox creates rook-ceph-tools via kubectl

func (*CephInstaller) GatherAllRookLogs 

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

func (*CephInstaller) GetNodeHostnames 

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

func (*CephInstaller) InstallRookOnK8sWithHostPathAndDevices 

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

InstallRookOnK8sWithHostPathAndDevices installs rook on k8s

func (*CephInstaller) UninstallRook 

func (h *CephInstaller) UninstallRook(helmInstalled bool, namespace string)

UninstallRookFromK8s uninstalls rook from k8s

func (*CephInstaller) UninstallRookFromMultipleNS 

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

UninstallRookFromK8s uninstalls rook from multiple namespaces in k8s

type CephManifests 

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
	GetObjectStore(namespace, name string, replicaCount, port int) string
	GetObjectStoreUser(namespace, name string, displayName string, store string) string
}

func NewCephManifests 

func NewCephManifests(version string) CephManifests

NewCephManifests gets the manifest type depending on the Rook version desired

type CephManifestsMaster 

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

CephManifestsMaster wraps rook yaml definitions

func (*CephManifestsMaster) GetBlockPoolDef 

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

func (*CephManifestsMaster) GetBlockPoolStorageClass 

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

func (*CephManifestsMaster) GetBlockPoolStorageClassAndPvcDef 

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

func (*CephManifestsMaster) GetBlockPvcDef 

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

func (*CephManifestsMaster) GetBlockStorageClassDef 

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

func (*CephManifestsMaster) GetCleanupPod 

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

GetCleanupPod gets a cleanup Pod manifest

func (*CephManifestsMaster) GetClusterRoles 

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

GetClusterRoles returns rook-cluster manifest

func (*CephManifestsMaster) GetFilesystem 

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) GetObjectStore 

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

func (*CephManifestsMaster) GetObjectStoreUser 

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

func (*CephManifestsMaster) GetRookCRDs 

func (m *CephManifestsMaster) GetRookCRDs() string

func (*CephManifestsMaster) GetRookCluster 

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

GetRookCluster returns rook-cluster manifest

func (*CephManifestsMaster) GetRookOperator 

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

GetRookOperator returns rook Operator manifest

func (*CephManifestsMaster) GetRookToolBox 

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

GetRookToolBox returns rook-toolbox manifest

type CephManifestsV0_8 

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

CephManifestsV0_8 wraps rook yaml definitions

func (*CephManifestsV0_8) GetBlockPoolDef 

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

func (*CephManifestsV0_8) GetBlockPoolStorageClass 

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

func (*CephManifestsV0_8) GetBlockPoolStorageClassAndPvcDef 

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

func (*CephManifestsV0_8) GetBlockPvcDef 

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

func (*CephManifestsV0_8) GetBlockStorageClassDef 

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

func (*CephManifestsV0_8) GetCleanupPod 

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

GetCleanupPod gets a cleanup Pod manifest

func (*CephManifestsV0_8) GetClusterRoles 

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

GetRookCluster returns rook-cluster manifest

func (*CephManifestsV0_8) GetFilesystem 

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

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

func (*CephManifestsV0_8) GetObjectStore 

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

func (*CephManifestsV0_8) GetObjectStoreUser 

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

func (*CephManifestsV0_8) GetRookCRDs 

func (m *CephManifestsV0_8) GetRookCRDs() string

func (*CephManifestsV0_8) GetRookCluster 

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

GetRookCluster returns rook-cluster manifest

func (*CephManifestsV0_8) GetRookOperator 

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

GetRookOperator returns rook Operator manifest

func (*CephManifestsV0_8) GetRookToolBox 

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

GetRookToolBox returns rook-toolbox manifest

type ClusterSettings 

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

type CockroachDBInstaller 

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

func NewCockroachDBInstaller 

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

func (*CockroachDBInstaller) CreateCockroachDBCluster 

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

func (*CockroachDBInstaller) CreateCockroachDBOperator 

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

func (*CockroachDBInstaller) GatherAllCockroachDBLogs 

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

func (*CockroachDBInstaller) InstallCockroachDB 

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

func (*CockroachDBInstaller) UninstallCockroachDB 

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

type CockroachDBManifests 

type CockroachDBManifests struct {
}

CockroachDBManifests holds the funcs which return the CockroachDB manifests

func (*CockroachDBManifests) GetCockroachDBCRDs 

func (i *CockroachDBManifests) GetCockroachDBCRDs() string

GetCockroachDBCRDs return the CockroachDB Cluster CRD

func (*CockroachDBManifests) GetCockroachDBCluster 

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

GetCockroachDBCluster return a CockroacDB Cluster object

func (*CockroachDBManifests) GetCockroachDBOperator 

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

GetCockroachDBOperator return the CockroachDB operator manifest

type EnvironmentManifest 

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 

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

func NewNFSInstaller 

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

func (*NFSInstaller) CreateNFSServer 

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

CreateNFSServer creates the NFS Server CRD instance

func (*NFSInstaller) CreateNFSServerOperator 

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

CreateNFSServerOperator creates nfs server in the provided namespace

func (*NFSInstaller) CreateNFSServerVolume 

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

CreateNFSServerVolume creates NFS export PV and PVC

func (*NFSInstaller) GatherAllNFSServerLogs 

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

GatherAllNFSServerLogs gathers all NFS Server logs

func (*NFSInstaller) GetNFSServerClusterIP 

func (h *NFSInstaller) GetNFSServerClusterIP(namespace string) (string, error)

GetNFSServerClusterIP gets the nfs server cluster ip on which it serves

func (*NFSInstaller) InstallNFSServer 

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

InstallNFSServer installs NFS operator, NFS CRD instance and NFS volume

func (*NFSInstaller) UninstallNFSServer 

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

UninstallNFSServer uninstalls the NFS Server from the given namespace

type NFSManifests 

type NFSManifests struct {
}

func (*NFSManifests) GetNFSServer 

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

GetNFSServer returns NFSServer CRD instance definition

func (*NFSManifests) GetNFSServerCRDs 

func (i *NFSManifests) GetNFSServerCRDs() string

GetNFSServerCRDs returns NFSServer CRD definition

func (*NFSManifests) GetNFSServerOperator 

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

GetNFSServerOperator returns the NFSServer operator definition

func (*NFSManifests) GetNFSServerPV 

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

GetNFSServerPV returns NFSServer PV definition

func (*NFSManifests) GetNFSServerPVC 

func (i *NFSManifests) GetNFSServerPVC() string

GetNFSServerPVC returns NFSServer PVC definition

type TestSuite 

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.