installer

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2022 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TridentAppLabelKey = "app"

	TridentLegacyLabelKey   = TridentAppLabelKey
	TridentLegacyLabelValue = "trident.netapp.io"
	TridentLegacyLabel      = TridentLegacyLabelKey + "=" + TridentLegacyLabelValue

	TridentCSILabelKey   = TridentAppLabelKey
	TridentCSILabelValue = "controller.csi.trident.netapp.io"
	TridentCSILabel      = TridentCSILabelKey + "=" + TridentCSILabelValue

	TridentPersistentObjectLabelKey   = "object"
	TridentPersistentObjectLabelValue = "persistent.trident.netapp.io"
	TridentPersistentObjectLabel      = TridentPersistentObjectLabelKey + "=" + TridentPersistentObjectLabelValue

	// Constants used for various resource names
	TridentCSI        = "trident-csi"
	TridentCSIWindows = "trident-csi-windows"
	TridentLegacy     = "trident"
	OpenShiftSCCName  = "trident"

	TridentControllerResourceName  = "trident-controller"
	TridentNodeLinuxResourceName   = "trident-node-linux"
	TridentNodeWindowsResourceName = "trident-node-windows"

	TridentEncryptionKeys = "trident-encryption-keys"

	CSIDriver  = "csi.trident.netapp.io"
	TridentPSP = "tridentpods"

	TridentNodeLabelKey   = TridentAppLabelKey
	TridentNodeLabelValue = "node.csi.trident.netapp.io"
	TridentNodeLabel      = TridentNodeLabelKey + "=" + TridentNodeLabelValue

	TridentVersionPodLabelKey   = TridentAppLabelKey
	TridentVersionPodLabelValue = "pod.version.trident.netapp.io"
	TridentVersionPodLabel      = TridentVersionPodLabelKey + "=" + TridentVersionPodLabelValue

	// This is used to Watch and List for deployment matching Trident CSI and Legacy labels
	LabelSelector = TridentAppLabelKey + " in (" + TridentCSILabelValue + ", " + TridentLegacyLabelValue + ")"

	// This is the key that stored in the objects created by the CR, value is decided based on the K8s version
	K8sVersionLabelKey = "k8s_version"

	ControllerServer = "127.0.0.1:8000"
	TridentContainer = "trident-main"

	// DefaultLogFormat is the the Trident logging format (text, json)
	DefaultLogFormat = "text"

	// DefaultProbePort is Trident's default port for K8S liveness/readiness probes
	DefaultProbePort = "17546"

	// DefaultKubeletDir is the host location of kubelet's internal state
	DefaultKubeletDir = "/var/lib/kubelet"

	CRAPIVersionKey = "apiVersion"
	CRController    = "controller"
	CRKind          = "kind"
	CRName          = "name"
	CRUID           = "uid"
)
View Source 
const (
	// CRD names
	BackendCRDName            = "tridentbackends.trident.netapp.io"
	BackendConfigCRDName      = "tridentbackendconfigs.trident.netapp.io"
	MirrorRelationshipCRDName = "tridentmirrorrelationships.trident.netapp.io"
	SnapshotInfoCRDName       = "tridentsnapshotinfos.trident.netapp.io"
	NodeCRDName               = "tridentnodes.trident.netapp.io"
	StorageClassCRDName       = "tridentstorageclasses.trident.netapp.io"
	TransactionCRDName        = "tridenttransactions.trident.netapp.io"
	VersionCRDName            = "tridentversions.trident.netapp.io"
	VolumeCRDName             = "tridentvolumes.trident.netapp.io"
	VolumePublicationCRDName  = "tridentvolumepublications.trident.netapp.io"
	SnapshotCRDName           = "tridentsnapshots.trident.netapp.io"
	VolumeReferenceCRDName    = "tridentvolumereferences.trident.netapp.io"

	VolumeSnapshotCRDName        = "volumesnapshots.snapshot.storage.k8s.io"
	VolumeSnapshotClassCRDName   = "volumesnapshotclasses.snapshot.storage.k8s.io"
	VolumeSnapshotContentCRDName = "volumesnapshotcontents.snapshot.storage.k8s.io"

	DefaultTimeout = 30
)

Variables

View Source 
var (
	DefaultTridentVersion = config.DefaultOrchestratorVersion

	DefaultTridentRepo = "netapp/trident:" // Default repo from where to pull Trident Image

	// TridentImage is the image that the operator installs by default
	TridentImage = DefaultTridentRepo + DefaultTridentVersion

	// This gets stored in the objects created by the CR
	TridentVersionLabelKey   = "trident_version"
	TridentVersionLabelValue = "v" + DefaultTridentVersion // need to append 'v', otherwise label freaks out
	TridentVersionLabel      = TridentVersionLabelKey + "=" + TridentVersionLabelValue
)
View Source 
var (
	CRDnames = []string{
		BackendCRDName,
		BackendConfigCRDName,
		MirrorRelationshipCRDName,
		SnapshotInfoCRDName,
		NodeCRDName,
		StorageClassCRDName,
		TransactionCRDName,
		VersionCRDName,
		VolumeCRDName,
		SnapshotCRDName,
		VolumeReferenceCRDName,
		VolumePublicationCRDName,
	}

	AlphaCRDNames = []string{
		VolumeSnapshotCRDName,
		VolumeSnapshotClassCRDName,
		VolumeSnapshotContentCRDName,
	}
)

Functions

This section is empty.

Types

type ExtendedK8sClient 

type ExtendedK8sClient interface {
	k8sclient.KubernetesClient

	CreateCustomResourceDefinition(crdName, crdYAML string) error
	PutCustomResourceDefinition(
		currentCRD *apiextensionv1.CustomResourceDefinition, crdName string, createCRD bool, newCRDYAML string,
	) error
	WaitForCRDEstablished(crdName string, timeout time.Duration) error
	DeleteCustomResourceDefinition(crdName, crdYAML string) error

	GetCSIDriverInformation(csiDriverName, appLabel string, shouldUpdate bool) (*storagev1.CSIDriver,
		[]storagev1.CSIDriver, bool, error)
	PutCSIDriver(currentCSIDriver *storagev1.CSIDriver, createCSIDriver bool, newCSIDriverYAML, appLabel string) error
	DeleteCSIDriverCR(csiDriverName, appLabel string) error
	RemoveMultipleCSIDriverCRs(unwantedCSIDriverCRs []storagev1.CSIDriver) error

	GetClusterRoleInformation(clusterRoleNames []string, appLabel string, shouldUpdate bool) (
		map[string]*rbacv1.ClusterRole, []rbacv1.ClusterRole, map[string]bool, error)
	PutClusterRole(
		currentClusterRole *rbacv1.ClusterRole, createClusterRole bool, newClusterRoleYAML, appLabel string,
	) error
	DeleteTridentClusterRole(clusterRoleNames []string, appLabel string) error
	RemoveMultipleClusterRoles(unwantedClusterRoles []rbacv1.ClusterRole) error

	GetClusterRoleBindingInformation(
		clusterRoleBindingNames []string, appLabel string, shouldUpdate bool,
	) (map[string]*rbacv1.ClusterRoleBinding,
		[]rbacv1.ClusterRoleBinding, map[string]bool, error)
	PutClusterRoleBinding(
		currentClusterRoleBinding *rbacv1.ClusterRoleBinding, createClusterRoleBinding bool,
		newClusterRoleBindingYAML, appLabel string,
	) error
	DeleteTridentClusterRoleBinding(clusterRoleBindingNames []string, appLabel string) error
	RemoveMultipleClusterRoleBindings(unwantedClusterRoleBindings []rbacv1.ClusterRoleBinding) error

	GetResourceQuotaInformation(resourceQuotaName, appLabel, namespace string) (*corev1.ResourceQuota,
		[]corev1.ResourceQuota, bool, error)
	PutResourceQuota(
		currentResourceQuota *corev1.ResourceQuota, createResourceQuota bool, newDeploymentYAML, appLabel string,
	) error
	DeleteTridentResourceQuota(nodeLabel string) error
	RemoveMultipleResourceQuotas(unwantedResourceQuotas []corev1.ResourceQuota) error

	GetDaemonSetInformation(nodeLabel, namespace string, isWindows bool) (*appsv1.DaemonSet, []appsv1.DaemonSet, bool,
		error)
	PutDaemonSet(
		currentDaemonSet *appsv1.DaemonSet, createDaemonSet bool, newDaemonSetYAML, nodeLabel, daemonSetName string,
	) error
	DeleteTridentDaemonSet(nodeLabel string) error
	RemoveMultipleDaemonSets(unwantedDaemonSets []appsv1.DaemonSet) error

	GetDeploymentInformation(deploymentName, appLabel, namespace string) (*appsv1.Deployment, []appsv1.Deployment, bool,
		error)
	PutDeployment(currentDeployment *appsv1.Deployment, createDeployment bool, newDeploymentYAML, appLabel string) error
	DeleteTridentDeployment(appLabel string) error
	RemoveMultipleDeployments(unwantedDeployments []appsv1.Deployment) error

	GetPodSecurityPolicyInformation(pspName, appLabel string, shouldUpdate bool) (*policyv1beta1.PodSecurityPolicy,
		[]policyv1beta1.PodSecurityPolicy, bool, error)
	PutPodSecurityPolicy(currentPSP *policyv1beta1.PodSecurityPolicy, createPSP bool, newPSPYAML, appLabel string) error
	DeleteTridentPodSecurityPolicy(pspName, appLabel string) error
	RemoveMultiplePodSecurityPolicies(unwantedPSPs []policyv1beta1.PodSecurityPolicy) error

	GetSecretInformation(secretName, appLabel, namespace string, shouldUpdate bool) (*corev1.Secret,
		[]corev1.Secret, bool, error)
	PutSecret(createSecret bool, newSecretYAML, secretName string) error
	DeleteTridentSecret(secretName, appLabel, namespace string) error
	RemoveMultipleSecrets(unwantedSecrets []corev1.Secret) error

	GetServiceInformation(serviceName, appLabel, namespace string, shouldUpdate bool) (*corev1.Service,
		[]corev1.Service, bool, error)
	PutService(currentService *corev1.Service, createService bool, newServiceYAML, appLabel string) error
	DeleteTridentService(serviceName, appLabel, namespace string) error
	RemoveMultipleServices(unwantedServices []corev1.Service) error

	GetServiceAccountInformation(
		serviceAccountNames []string, appLabel, namespace string, shouldUpdate bool,
	) (map[string]*corev1.ServiceAccount,
		[]corev1.ServiceAccount, map[string][]string, map[string]bool, error)
	PutServiceAccount(
		currentServiceAccount *corev1.ServiceAccount, createServiceAccount bool, newServiceAccountYAML, appLabel string,
	) (bool,
		error)
	DeleteTridentServiceAccount(serviceAccountNames []string, appLabel, namespace string) error
	RemoveMultipleServiceAccounts(unwantedServiceAccounts []corev1.ServiceAccount) error

	GetTridentOpenShiftSCCInformation(openShiftSCCNames, openShiftSCCUserNames []string, shouldUpdate bool) (map[string][]byte,
		map[string]bool, map[string]bool, error)
	PutOpenShiftSCC(
		currentOpenShiftSCCJSON []byte,
		createOpenShiftSCC bool, newOpenShiftSCCYAML string,
	) error
	DeleteOpenShiftSCC(
		openShiftSCCUserNames, openShiftSCCNames []string,
		appLabelValue string,
	) error

	DeleteTridentStatefulSet(appLabel string) error
	RemoveMultipleStatefulSets(unwantedStatefulSets []appsv1.StatefulSet) error

	DeleteTransientVersionPod(tridentVersionPodLabel string) error
	RemoveMultiplePods(unwantedPods []corev1.Pod) error

	ExecPodForVersionInformation(podName string, cmd []string, timeout time.Duration) ([]byte, error)
	GetCSISnapshotterVersion(currentDeployment *appsv1.Deployment) string
}

ExtendedK8sClient extends the vanilla k8s client Interface and is responsible for enabling the TridentInstaller.

func NewExtendedK8sClient 

func NewExtendedK8sClient(kubeConfig *rest.Config, namespace string, k8sTimeout time.Duration) (ExtendedK8sClient,
	error,
)

NewExtendedK8sClient returns a concrete ExtendedK8sClient object

type Installer 

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

func (*Installer) CreateOrPatchCRD 

func (i *Installer) CreateOrPatchCRD(crdName, crdYAML string, performOperationOnce bool) error

CreateOrPatchCRD creates and establishes a CRD or patches an existing one. TODO: Once Trident v22.01 approaches EOL or CRD versioning schema is established, 

re-evaluate if performOperationOnce is necessary.

func (*Installer) InstallOrPatchTrident 

func (i *Installer) InstallOrPatchTrident(
	cr netappv1.TridentOrchestrator, currentInstallationVersion string, k8sUpdateNeeded, crdUpdateNeeded bool,
) (*netappv1.TridentOrchestratorSpecValues, string, error)

func (*Installer) ObliviateCRDs 

func (i *Installer) ObliviateCRDs() error

func (*Installer) TridentDaemonSetInformation 

func (i *Installer) TridentDaemonSetInformation() (*appsv1.DaemonSet,
	[]appsv1.DaemonSet, bool, error,
)

TridentDaemonSetInformation identifies the Operator based Trident CSI daemonset and unwanted daemonsets, this method can be used for multiple purposes at different point during the Reconcile so it makes sense to keep it separate from the createOrPatchTridentDaemonSet

func (*Installer) TridentDeploymentInformation 

func (i *Installer) TridentDeploymentInformation(
	deploymentLabel string,
) (*appsv1.Deployment, []appsv1.Deployment, bool, error)

TridentDeploymentInformation identifies the Operator based Trident CSI deployment and unwanted deployments, this method can be used for multiple purposes at different point during the Reconcile so it makes sense to keep it separate from the createOrPatchTridentDeployment

func (*Installer) UninstallCSIPreviewTrident 

func (i *Installer) UninstallCSIPreviewTrident() error

func (*Installer) UninstallLegacyTrident 

func (i *Installer) UninstallLegacyTrident() error

func (*Installer) UninstallTrident 

func (i *Installer) UninstallTrident() error

type K8sClient 

type K8sClient struct {
	k8sclient.KubernetesClient
}

K8sClient is a method receiver that implements the ExtendedK8sClient interface

func (*K8sClient) CreateCustomResourceDefinition 

func (k *K8sClient) CreateCustomResourceDefinition(crdName, crdYAML string) error

CreateCustomResourceDefinition creates a CRD.

func (*K8sClient) DeleteCSIDriverCR 

func (k *K8sClient) DeleteCSIDriverCR(csiDriverName, appLabel string) error

DeleteCSIDriverCR deletes a CSI Driver.

func (*K8sClient) DeleteCustomResourceDefinition 

func (k *K8sClient) DeleteCustomResourceDefinition(crdName, crdYAML string) error

DeleteCustomResourceDefinition deletes a CRD.

func (*K8sClient) DeleteOpenShiftSCC 

func (k *K8sClient) DeleteOpenShiftSCC(
	openShiftSCCUserNames, openShiftSCCNames []string,
	appLabelValue string,
) error

DeleteOpenShiftSCC deletes an Operator-based OpenShiftSCC associated with Trident.

func (*K8sClient) DeleteTransientVersionPod 

func (k *K8sClient) DeleteTransientVersionPod(versionPodLabel string) error

DeleteTransientVersionPod deletes the temporary version pod used by the operator

func (*K8sClient) DeleteTridentClusterRole 

func (k *K8sClient) DeleteTridentClusterRole(clusterRoleNames []string, appLabel string) error

DeleteTridentClusterRole deletes Cluster Role(s) associated with Trident.

func (*K8sClient) DeleteTridentClusterRoleBinding 

func (k *K8sClient) DeleteTridentClusterRoleBinding(clusterRoleBindingNames []string, appLabel string) error

DeleteTridentClusterRoleBinding deletes Cluster Role Binding(s) associated with Trident.

func (*K8sClient) DeleteTridentDaemonSet 

func (k *K8sClient) DeleteTridentDaemonSet(nodeLabel string) error

DeleteTridentDaemonSet deletes a Trident DaemonSet.

func (*K8sClient) DeleteTridentDeployment 

func (k *K8sClient) DeleteTridentDeployment(appLabel string) error

DeleteTridentDeployment deletes a Trident Deployment.

func (*K8sClient) DeleteTridentPodSecurityPolicy 

func (k *K8sClient) DeleteTridentPodSecurityPolicy(pspName, appLabel string) error

DeleteTridentPodSecurityPolicy deletes a PSP.

func (*K8sClient) DeleteTridentResourceQuota 

func (k *K8sClient) DeleteTridentResourceQuota(nodeLabel string) error

DeleteTridentResourceQuota deletes a Trident Resource Quota.

func (*K8sClient) DeleteTridentSecret 

func (k *K8sClient) DeleteTridentSecret(secretName, appLabel, namespace string) error

DeleteTridentSecret deletes a Secret associated with Trident.

func (*K8sClient) DeleteTridentService 

func (k *K8sClient) DeleteTridentService(serviceName, appLabel, namespace string) error

DeleteTridentService deletes an Operator-based Service associated with Trident.

func (*K8sClient) DeleteTridentServiceAccount 

func (k *K8sClient) DeleteTridentServiceAccount(serviceAccountNames []string, appLabel, namespace string) error

DeleteTridentServiceAccount deletes an Operator-based Service Account associated with Trident.

func (*K8sClient) DeleteTridentStatefulSet 

func (k *K8sClient) DeleteTridentStatefulSet(appLabel string) error

DeleteTridentStatefulSet deletes an Operator-based StatefulSet associated with Trident.

func (*K8sClient) ExecPodForVersionInformation 

func (k *K8sClient) ExecPodForVersionInformation(podName string, cmd []string, timeout time.Duration) ([]byte, error)

ExecPodForVersionInformation takes the pod name and command to execute the command into the container matching the pod name

func (*K8sClient) GetCSIDriverInformation 

func (k *K8sClient) GetCSIDriverInformation(csiDriverName, appLabel string, shouldUpdate bool) (*storagev1.CSIDriver,
	[]storagev1.CSIDriver, bool, error,
)

GetCSIDriverInformation gets the CSI drivers info in a cluster associated with Trident.

func (*K8sClient) GetCSISnapshotterVersion 

func (k *K8sClient) GetCSISnapshotterVersion(currentDeployment *appsv1.Deployment) string

GetCSISnapshotterVersion uses the below approach to identify CSI Snapshotter Version: If successful in retrieving the CSI Snapshotter CRD Version, use it as it is Else if failed, then CSI Snapshotter CRD Version will be empty then get existing CSI Snapshotter Version as v1.

func (*K8sClient) GetClusterRoleBindingInformation 

func (k *K8sClient) GetClusterRoleBindingInformation(
	clusterRoleBindingNames []string, appLabel string, shouldUpdate bool,
) (map[string]*rbacv1.ClusterRoleBinding,
	[]rbacv1.ClusterRoleBinding, map[string]bool, error,
)

GetClusterRoleBindingInformation gets the info on a Cluster Role Binding associated with Trident.

func (*K8sClient) GetClusterRoleInformation 

func (k *K8sClient) GetClusterRoleInformation(clusterRoleNames []string, appLabel string, shouldUpdate bool) (
	map[string]*rbacv1.ClusterRole, []rbacv1.ClusterRole, map[string]bool, error,
)

GetClusterRoleInformation gets the Cluster Role info.

func (*K8sClient) GetDaemonSetInformation 

func (k *K8sClient) GetDaemonSetInformation(nodeLabel, namespace string, isWindows bool) (*appsv1.DaemonSet,
	[]appsv1.DaemonSet, bool, error,
)

GetDaemonSetInformation identifies the Operator-based Trident daemonset information and any unwanted daemonsets

func (*K8sClient) GetDeploymentInformation 

func (k *K8sClient) GetDeploymentInformation(deploymentName, appLabel, namespace string) (*appsv1.Deployment,
	[]appsv1.Deployment, bool, error,
)

GetDeploymentInformation identifies the Operator-based Trident deployment information and any unwanted deployments

func (*K8sClient) GetPodSecurityPolicyInformation 

func (k *K8sClient) GetPodSecurityPolicyInformation(
	pspName, appLabel string, shouldUpdate bool,
) (*policyv1beta1.PodSecurityPolicy,
	[]policyv1beta1.PodSecurityPolicy, bool, error,
)

GetPodSecurityPolicyInformation identifies the Operator-based Trident PSP information and any unwanted PSPs.

func (*K8sClient) GetResourceQuotaInformation 

func (k *K8sClient) GetResourceQuotaInformation(
	resourcequotaName, label, namespace string,
) (*corev1.ResourceQuota, []corev1.ResourceQuota, bool, error)

GetResourceQuotaInformation identifies the Operator-based Trident resource quota information and any unwanted resource quotas

func (*K8sClient) GetSecretInformation 

func (k *K8sClient) GetSecretInformation(secretName, appLabel, namespace string, shouldUpdate bool) (*corev1.Secret,
	[]corev1.Secret, bool, error,
)

GetSecretInformation identifies the Operator-based Trident Secret information.

func (*K8sClient) GetServiceAccountInformation 

func (k *K8sClient) GetServiceAccountInformation(
	serviceAccountNames []string, appLabel, namespace string, shouldUpdate bool,
) (map[string]*corev1.ServiceAccount,
	[]corev1.ServiceAccount, map[string][]string, map[string]bool, error,
)

GetServiceAccountInformation identifies the Operator-based Trident Service Account info and any unwanted Service Accounts.

func (*K8sClient) GetServiceInformation 

func (k *K8sClient) GetServiceInformation(serviceName, appLabel, namespace string, shouldUpdate bool) (*corev1.Service,
	[]corev1.Service, bool, error,
)

GetServiceInformation identifies the Operator-based Trident Service information.

func (*K8sClient) GetTridentOpenShiftSCCInformation 

func (k *K8sClient) GetTridentOpenShiftSCCInformation(
	openShiftSCCNames, openShiftSCCUserNames []string, shouldUpdate bool,
) (map[string][]byte,
	map[string]bool, map[string]bool, error,
)

GetTridentOpenShiftSCCInformation gets OpenShiftSCC info with a supplied name, username and determines if new OpenShiftSCC should be created

func (*K8sClient) PutCSIDriver 

func (k *K8sClient) PutCSIDriver(
	currentCSIDriver *storagev1.CSIDriver, createCSIDriver bool, newCSIDriverYAML, appLabel string,
) error

PutCSIDriver creates or updates a CSI Driver associated with Trident.

func (*K8sClient) PutClusterRole 

func (k *K8sClient) PutClusterRole(
	currentClusterRole *rbacv1.ClusterRole, reuseClusterRole bool, newClusterRoleYAML, appLabel string,
) error

PutClusterRole creates or updates a Cluster Role associated with Trident.

func (*K8sClient) PutClusterRoleBinding 

func (k *K8sClient) PutClusterRoleBinding(
	currentClusterRoleBinding *rbacv1.ClusterRoleBinding, reuseClusterRoleBinding bool,
	newClusterRoleBindingYAML, appLabel string,
) error

PutClusterRoleBinding creates or updates a Cluster Role Binding associated with Trident.

func (*K8sClient) PutCustomResourceDefinition 

func (k *K8sClient) PutCustomResourceDefinition(
	currentCRD *apiextensionv1.CustomResourceDefinition, crdName string, createCRD bool, newCRDYAML string,
) error

PutCustomResourceDefinition ensures a CRD is created and on the most recent CRD version.

func (*K8sClient) PutDaemonSet 

func (k *K8sClient) PutDaemonSet(
	currentDaemonSet *appsv1.DaemonSet, createDaemonSet bool, newDaemonSetYAML, nodeLabel, daemonSetName string,
) error

PutDaemonSet creates or updates a Trident DaemonSet.

func (*K8sClient) PutDeployment 

func (k *K8sClient) PutDeployment(
	currentDeployment *appsv1.Deployment, createDeployment bool, newDeploymentYAML, appLabel string,
) error

PutDeployment creates or updates a Trident Deployment.

func (*K8sClient) PutOpenShiftSCC 

func (k *K8sClient) PutOpenShiftSCC(
	currentOpenShiftSCCJSON []byte,
	reuseOpenShiftSCC bool, newOpenShiftSCCYAML string,
) error

PutOpenShiftSCC creates or updates OpenShiftSCCs associated with Trident.

func (*K8sClient) PutPodSecurityPolicy 

func (k *K8sClient) PutPodSecurityPolicy(
	currentPSP *policyv1beta1.PodSecurityPolicy, createPSP bool, newPSPYAML, appLabel string,
) error

PutPodSecurityPolicy creates or updates a PSP.

func (*K8sClient) PutResourceQuota 

func (k *K8sClient) PutResourceQuota(
	currentResourceQuota *corev1.ResourceQuota, createResourceQuota bool, newResourceQuotaYAML, appLabel string,
) error

PutResourceQuota will create a new Resource Quota or patch an existing one.

func (*K8sClient) PutSecret 

func (k *K8sClient) PutSecret(createSecret bool, newSecretYAML, secretName string) error

PutSecret creates or updates a Secret associated with Trident.

func (*K8sClient) PutService 

func (k *K8sClient) PutService(
	currentService *corev1.Service, createService bool, newServiceYAML, appLabel string,
) error

PutService creates or updates a Service associated with Trident.

func (*K8sClient) PutServiceAccount 

func (k *K8sClient) PutServiceAccount(
	currentServiceAccount *corev1.ServiceAccount, reuseServiceAccount bool, newServiceAccountYAML, appLabel string,
) (bool,
	error,
)

PutServiceAccount creates or updates a Service Account associated with Trident.

func (*K8sClient) RemoveMultipleCSIDriverCRs 

func (k *K8sClient) RemoveMultipleCSIDriverCRs(unwantedCSIDriverCRs []storagev1.CSIDriver) error

RemoveMultipleCSIDriverCRs removes a list of unwanted CSI drivers in a cluster.

func (*K8sClient) RemoveMultipleClusterRoleBindings 

func (k *K8sClient) RemoveMultipleClusterRoleBindings(unwantedClusterRoleBindings []rbacv1.ClusterRoleBinding) error

RemoveMultipleClusterRoleBindings removes a list of unwanted cluster role bindings in a cluster.

func (*K8sClient) RemoveMultipleClusterRoles 

func (k *K8sClient) RemoveMultipleClusterRoles(unwantedClusterRoles []rbacv1.ClusterRole) error

RemoveMultipleClusterRoles removes a list of unwanted cluster roles in a cluster.

func (*K8sClient) RemoveMultipleDaemonSets 

func (k *K8sClient) RemoveMultipleDaemonSets(unwantedDaemonSets []appsv1.DaemonSet) error

RemoveMultipleDaemonSets removes a list of unwanted beta CSI drivers in a namespace

func (*K8sClient) RemoveMultipleDeployments 

func (k *K8sClient) RemoveMultipleDeployments(unwantedDeployments []appsv1.Deployment) error

RemoveMultipleDeployments removes a list of unwanted beta CSI drivers in a namespace

func (*K8sClient) RemoveMultiplePodSecurityPolicies 

func (k *K8sClient) RemoveMultiplePodSecurityPolicies(unwantedPSPs []policyv1beta1.PodSecurityPolicy) error

RemoveMultiplePodSecurityPolicies removes a list of unwanted pod security policies in a cluster.

func (*K8sClient) RemoveMultiplePods 

func (k *K8sClient) RemoveMultiplePods(unwantedPods []corev1.Pod) error

RemoveMultiplePods removes a list of unwanted pods in a namespace

func (*K8sClient) RemoveMultipleResourceQuotas 

func (k *K8sClient) RemoveMultipleResourceQuotas(unwantedResourceQuotas []corev1.ResourceQuota) error

RemoveMultipleResourceQuotas removes a list of unwanted resource quotas in a namespace

func (*K8sClient) RemoveMultipleSecrets 

func (k *K8sClient) RemoveMultipleSecrets(unwantedSecrets []corev1.Secret) error

RemoveMultipleSecrets removes a list of unwanted secrets in a namespace.

func (*K8sClient) RemoveMultipleServiceAccounts 

func (k *K8sClient) RemoveMultipleServiceAccounts(unwantedServiceAccounts []corev1.ServiceAccount) error

RemoveMultipleServiceAccounts removes a list of unwanted service accounts in a namespace

func (*K8sClient) RemoveMultipleServices 

func (k *K8sClient) RemoveMultipleServices(unwantedServices []corev1.Service) error

RemoveMultipleServices removes a list of unwanted services in a namespace

func (*K8sClient) RemoveMultipleStatefulSets 

func (k *K8sClient) RemoveMultipleStatefulSets(unwantedStatefulSets []appsv1.StatefulSet) error

RemoveMultipleStatefulSets removes a list of unwanted statefulsets in a namespace

func (*K8sClient) WaitForCRDEstablished 

func (k *K8sClient) WaitForCRDEstablished(crdName string, timeout time.Duration) error

WaitForCRDEstablished waits until a CRD is Established.

type TridentInstaller 

type TridentInstaller interface {
	CreateOrPatchCRD(crdName, crdYAML string, performOperationOnce bool) error
	InstallOrPatchTrident(
		cr v15.TridentOrchestrator, currentInstallationVersion string, shouldUpdate, crdUpdateNeeded bool,
	) (*v15.TridentOrchestratorSpecValues, string, error)
	ObliviateCRDs() error
	TridentDeploymentInformation(deploymentLabel string) (*appsv1.Deployment, []appsv1.Deployment, bool, error)
	TridentDaemonSetInformation() (*appsv1.DaemonSet, []appsv1.DaemonSet, bool, error)
	UninstallTrident() error
	UninstallCSIPreviewTrident() error
	UninstallLegacyTrident() error
}

TridentInstaller is responsible for installing, patching, or uninstalling orchestrator controlled instances of Trident.

func NewInstaller 

func NewInstaller(kubeConfig *rest.Config, namespace string, timeout int) (TridentInstaller, error)

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.