installer

Documentation

Index

• func BlockResourceOperation(k8sh *utils.K8sHelper, yaml string, action string) (string, error)
• func GetBlockPoolDef(poolName string, namespace string, replicaSize string) string
• func GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, blockName string) string
• func GetBlockPvcDef(claimName string, storageClassName string) string
• func GetBlockStorageClassDef(poolName string, storageClassName string, namespace string) string
• func IsAdditionalDeviceAvailableOnCluster() bool
• func SystemNamespace(namespace string) string
• type InstallData
  • func NewK8sInstallData() *InstallData
  • func (i *InstallData) GetRookCluster(namespace, storeType, dataDirHostPath string, useAllDevices bool, mons int) string
  • func (i *InstallData) GetRookOperator(namespace string) string
  • func (i *InstallData) GetRookToolBox(namespace string) string
• type InstallHelper
  • func NewK8sRookhelper(clientset *kubernetes.Clientset, t func() *testing.T) *InstallHelper
  • func (h *InstallHelper) CleanupCluster(clusterName string)
  • func (h *InstallHelper) CreateK8sRookCluster(namespace string, storeType string) (err error)
  • func (h *InstallHelper) CreateK8sRookClusterWithHostPath(namespace string, storeType string, dataDirHostPath string, mons int) (err error)
  • func (h *InstallHelper) CreateK8sRookClusterWithHostPathAndDevices(namespace, storeType, dataDirHostPath string, useAllDevices bool, mons int) (err error)
  • func (h *InstallHelper) CreateK8sRookOperator(namespace string) (err error)
  • func (h *InstallHelper) CreateK8sRookOperatorViaHelm(namespace string) error
  • func (h *InstallHelper) CreateK8sRookToolbox(namespace string) (err error)
  • func (h *InstallHelper) InstallRookOnK8s(namespace, storeType string, mons int) (bool, error)
  • func (h *InstallHelper) InstallRookOnK8sWithHostPathAndDevices(namespace, storeType, dataDirHostPath string, useDevices bool, mons int) (bool, error)
  • func (h *InstallHelper) UninstallRookFromK8s(namespace string, helmInstalled bool)

Functions

func BlockResourceOperation

func BlockResourceOperation(k8sh *utils.K8sHelper, yaml string, action string) (string, error)

func GetBlockPoolDef

func GetBlockPoolDef(poolName string, namespace string, replicaSize string) string

func GetBlockPoolStorageClassAndPvcDef

func GetBlockPoolStorageClassAndPvcDef(namespace string, poolName string, storageClassName string, blockName string) string

func GetBlockPvcDef

func GetBlockPvcDef(claimName string, storageClassName string) string

func GetBlockStorageClassDef

func GetBlockStorageClassDef(poolName string, storageClassName string, namespace string) string

func IsAdditionalDeviceAvailableOnCluster

func IsAdditionalDeviceAvailableOnCluster() bool

func SystemNamespace

func SystemNamespace(namespace string) string

Types

type InstallData

type InstallData struct {
}

InstallData wraps rook yaml definitions

func NewK8sInstallData

func NewK8sInstallData() *InstallData

NewK8sInstallData creates new instance of InstallData struct

func (*InstallData) GetRookCluster

func (i *InstallData) GetRookCluster(namespace, storeType, dataDirHostPath string, useAllDevices bool, mons int) string

GetRookCluster returns rook-cluster manifest

func (*InstallData) GetRookOperator

func (i *InstallData) GetRookOperator(namespace string) string

GetRookOperator returns rook Operator manifest

func (*InstallData) GetRookToolBox

func (i *InstallData) GetRookToolBox(namespace string) string

GetRookToolBox returns rook-toolbox manifest

type InstallHelper

type InstallHelper struct {
	Env objects.EnvironmentManifest

	T func() *testing.T
	// contains filtered or unexported fields
}

InstallHelper wraps installing and uninstalling rook on a platform

func NewK8sRookhelper

func NewK8sRookhelper(clientset *kubernetes.Clientset, t func() *testing.T) *InstallHelper

NewK8sRookhelper creates new instance of InstallHelper

func (*InstallHelper) CleanupCluster

func (h *InstallHelper) CleanupCluster(clusterName string)

CleanupCluster deletes a rook cluster for a namespace

func (*InstallHelper) CreateK8sRookCluster

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

func (*InstallHelper) CreateK8sRookClusterWithHostPath

func (h *InstallHelper) CreateK8sRookClusterWithHostPath(namespace string, storeType string, dataDirHostPath string, mons int) (err error)

func (*InstallHelper) CreateK8sRookClusterWithHostPathAndDevices

func (h *InstallHelper) CreateK8sRookClusterWithHostPathAndDevices(namespace, storeType, dataDirHostPath string, useAllDevices bool, mons int) (err error)

CreateK8sRookCluster creates rook cluster via kubectl

func (*InstallHelper) CreateK8sRookOperator

func (h *InstallHelper) CreateK8sRookOperator(namespace string) (err error)

CreateK8sRookOperator creates rook-operator via kubectl

func (*InstallHelper) CreateK8sRookOperatorViaHelm

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

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

func (*InstallHelper) CreateK8sRookToolbox

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

CreateK8sRookToolbox creates rook-tools via kubectl

func (*InstallHelper) InstallRookOnK8s

func (h *InstallHelper) InstallRookOnK8s(namespace, storeType string, mons int) (bool, error)

func (*InstallHelper) InstallRookOnK8sWithHostPathAndDevices

func (h *InstallHelper) InstallRookOnK8sWithHostPathAndDevices(namespace, storeType, dataDirHostPath string, useDevices bool, mons int) (bool, error)

InstallRookOnK8s installs rook on k8s

func (*InstallHelper) UninstallRookFromK8s

func (h *InstallHelper) UninstallRookFromK8s(namespace string, helmInstalled bool)

UninstallRookFromK8s uninstalls rook from k8s