Versions in this module Expand all Collapse all v0 v0.0.2 Nov 10, 2022 v0.0.1 Feb 21, 2020 Changes in this version + const CLIKubernetes + const CLIOpenShift + const CSIDriverCRDYAML + const CSIDriverCRYAML + const CSINodeInfoCRDYAML + const FlavorKubernetes + const FlavorOpenShift + const InstallerSecurityPolicyYAML + const PodSecurityPolicyYAML + const TridentFinalizer + const YAMLSeparator + func GetCRDNames() []string + func GetCRDsYAML() string + func GetCSIDaemonSetYAML(tridentImage, label, logFormat string, debug bool, version *utils.Version) string + func GetCSIDeploymentYAML(tridentImage, label, logFormat string, debug bool, version *utils.Version) string + func GetCSIDriverCRDYAML() string + func GetCSIDriverCRYAML() string + func GetCSINodeInfoCRDYAML() string + func GetCSIServiceYAML(label string) string + func GetClusterRoleBindingYAML(namespace string, flavor OrchestratorFlavor, csi bool) string + func GetClusterRoleYAML(flavor OrchestratorFlavor, csi bool) string + func GetDeploymentYAML(tridentImage, label, logFormat string, debug bool) string + func GetEmptyConfigMapYAML(label, name, namespace string) string + func GetInstallerClusterRoleBindingYAML(namespace string, flavor OrchestratorFlavor) string + func GetInstallerClusterRoleYAML(flavor OrchestratorFlavor) string + func GetInstallerPodYAML(label, tridentImage string, commandArgs []string) string + func GetInstallerSecurityPolicyYAML() string + func GetInstallerServiceAccountYAML() string + func GetMigratorPodYAML(pvcName, tridentImage, etcdImage, label string, csi bool, commandArgs []string) string + func GetNamespaceYAML(namespace string) string + func GetOpenShiftSCCQueryYAML(scc string) string + func GetPodSecurityPolicyYAML() string + func GetSecretYAML(secretName, namespace, label string, data map[string]string, ...) string + func GetServiceAccountYAML(csi bool) string + func GetUninstallerPodYAML(label, tridentImage string, commandArgs []string) string + type Interface interface + AddFinalizerToCRD func(crdName string) error + AddTridentUserToOpenShiftSCC func(user, scc string) error + CLI func() string + CheckCRDExists func(crdName string) (bool, error) + CheckConfigMapExistsByLabel func(label string, allNamespaces bool) (bool, string, error) + CheckDaemonSetExistsByLabel func(label string, allNamespaces bool) (bool, string, error) + CheckDeploymentExistsByLabel func(label string, allNamespaces bool) (bool, string, error) + CheckNamespaceExists func(namespace string) (bool, error) + CheckPVCBound func(pvcName string) (bool, error) + CheckPVCExists func(pvcName string) (bool, error) + CheckPVExists func(pvName string) (bool, error) + CheckPodExistsByLabel func(label string, allNamespaces bool) (bool, string, error) + CheckSecretExists func(secretName string) (bool, error) + CheckServiceExistsByLabel func(label string, allNamespaces bool) (bool, string, error) + CheckStatefulSetExistsByLabel func(label string, allNamespaces bool) (bool, string, error) + CreateCHAPSecret func(secretName, accountName, initiatorSecret, targetSecret string) (*v1.Secret, error) + CreateConfigMapFromDirectory func(path, name, label string) error + CreateObjectByFile func(filePath string) error + CreateObjectByYAML func(yaml string) error + CreateSecret func(secret *v1.Secret) (*v1.Secret, error) + DeleteCRD func(crdName string) error + DeleteConfigMapByLabel func(label string) error + DeleteDaemonSetByLabel func(label string) error + DeleteDeploymentByLabel func(label string) error + DeleteObjectByFile func(filePath string, ignoreNotFound bool) error + DeleteObjectByYAML func(yaml string, ignoreNotFound bool) error + DeletePVByLabel func(label string) error + DeletePVCByLabel func(label string) error + DeletePodByLabel func(label string) error + DeleteSecret func(secretName string) error + DeleteSecretByLabel func(label string) error + DeleteServiceByLabel func(label string) error + DeleteStatefulSetByLabel func(label string) error + Exec func(podName, containerName string, commandArgs []string) ([]byte, error) + Flavor func() OrchestratorFlavor + FollowPodLogs func(pod, container, namespace string, logLineCallback LogLineCallback) + GetCRD func(crdName string) (*apiextensionv1beta1.CustomResourceDefinition, error) + GetCRDClient func() (*crdclient.Clientset, error) + GetConfigMapByLabel func(label string, allNamespaces bool) (*v1.ConfigMap, error) + GetConfigMapsByLabel func(label string, allNamespaces bool) ([]v1.ConfigMap, error) + GetDaemonSetByLabel func(label string, allNamespaces bool) (*appsv1.DaemonSet, error) + GetDaemonSetsByLabel func(label string, allNamespaces bool) ([]appsv1.DaemonSet, error) + GetDeploymentByLabel func(label string, allNamespaces bool) (*appsv1.Deployment, error) + GetDeploymentsByLabel func(label string, allNamespaces bool) ([]appsv1.Deployment, error) + GetPV func(pvName string) (*v1.PersistentVolume, error) + GetPVByLabel func(label string) (*v1.PersistentVolume, error) + GetPVC func(pvcName string) (*v1.PersistentVolumeClaim, error) + GetPVCByLabel func(label string, allNamespaces bool) (*v1.PersistentVolumeClaim, error) + GetPodByLabel func(label string, allNamespaces bool) (*v1.Pod, error) + GetPodsByLabel func(label string, allNamespaces bool) ([]v1.Pod, error) + GetSecret func(secretName string) (*v1.Secret, error) + GetSecretByLabel func(label string, allNamespaces bool) (*v1.Secret, error) + GetServiceByLabel func(label string, allNamespaces bool) (*v1.Service, error) + GetServicesByLabel func(label string, allNamespaces bool) ([]v1.Service, error) + GetStatefulSetByLabel func(label string, allNamespaces bool) (*appsv1.StatefulSet, error) + GetStatefulSetsByLabel func(label string, allNamespaces bool) ([]appsv1.StatefulSet, error) + Namespace func() string + RemoveFinalizerFromCRD func(crdName string) error + RemoveTridentUserFromOpenShiftSCC func(user, scc string) error + ServerVersion func() *utils.Version + SetNamespace func(namespace string) + UpdateSecret func(secret *v1.Secret) (*v1.Secret, error) + Version func() *version.Info + func NewFakeKubeClient() (Interface, error) + func NewKubeClient(config *rest.Config, namespace string, k8sTimeout time.Duration) (Interface, error) + func NewKubectlClient(namespace string, k8sTimeout time.Duration) (Interface, error) + type KubeClient struct + func (k *KubeClient) AddFinalizerToCRD(crdName string) error + func (k *KubeClient) AddTridentUserToOpenShiftSCC(user, scc string) error + func (k *KubeClient) CLI() string + func (k *KubeClient) CheckCRDExists(crdName string) (bool, error) + func (k *KubeClient) CheckConfigMapExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (k *KubeClient) CheckDaemonSetExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (k *KubeClient) CheckDeploymentExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (k *KubeClient) CheckNamespaceExists(namespace string) (bool, error) + func (k *KubeClient) CheckPVCBound(pvcName string) (bool, error) + func (k *KubeClient) CheckPVCExists(pvc string) (bool, error) + func (k *KubeClient) CheckPVExists(pvName string) (bool, error) + func (k *KubeClient) CheckPodExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (k *KubeClient) CheckSecretExists(secretName string) (bool, error) + func (k *KubeClient) CheckServiceExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (k *KubeClient) CheckStatefulSetExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (k *KubeClient) CreateCHAPSecret(secretName, accountName, initiatorSecret, targetSecret string) (*v1.Secret, error) + func (k *KubeClient) CreateConfigMapFromDirectory(path, name, label string) error + func (k *KubeClient) CreateObjectByFile(filePath string) error + func (k *KubeClient) CreateObjectByYAML(yamlData string) error + func (k *KubeClient) CreateSecret(secret *v1.Secret) (*v1.Secret, error) + func (k *KubeClient) DeleteCRD(crdName string) error + func (k *KubeClient) DeleteConfigMapByLabel(label string) error + func (k *KubeClient) DeleteDaemonSetByLabel(label string) error + func (k *KubeClient) DeleteDeploymentByLabel(label string) error + func (k *KubeClient) DeleteObjectByFile(filePath string, ignoreNotFound bool) error + func (k *KubeClient) DeleteObjectByYAML(yamlData string, ignoreNotFound bool) error + func (k *KubeClient) DeletePVByLabel(label string) error + func (k *KubeClient) DeletePVCByLabel(label string) error + func (k *KubeClient) DeletePodByLabel(label string) error + func (k *KubeClient) DeleteSecret(secretName string) error + func (k *KubeClient) DeleteSecretByLabel(label string) error + func (k *KubeClient) DeleteServiceByLabel(label string) error + func (k *KubeClient) DeleteStatefulSetByLabel(label string) error + func (k *KubeClient) Exec(podName, containerName string, commandArgs []string) ([]byte, error) + func (k *KubeClient) Flavor() OrchestratorFlavor + func (k *KubeClient) FollowPodLogs(pod, container, namespace string, logLineCallback LogLineCallback) + func (k *KubeClient) GetCRD(crdName string) (*apiextensionv1beta1.CustomResourceDefinition, error) + func (k *KubeClient) GetCRDClient() (*crdclient.Clientset, error) + func (k *KubeClient) GetConfigMapByLabel(label string, allNamespaces bool) (*v1.ConfigMap, error) + func (k *KubeClient) GetConfigMapsByLabel(label string, allNamespaces bool) ([]v1.ConfigMap, error) + func (k *KubeClient) GetDaemonSetByLabel(label string, allNamespaces bool) (*appsv1.DaemonSet, error) + func (k *KubeClient) GetDaemonSetsByLabel(label string, allNamespaces bool) ([]appsv1.DaemonSet, error) + func (k *KubeClient) GetDeploymentByLabel(label string, allNamespaces bool) (*appsv1.Deployment, error) + func (k *KubeClient) GetDeploymentsByLabel(label string, allNamespaces bool) ([]appsv1.Deployment, error) + func (k *KubeClient) GetPV(pvName string) (*v1.PersistentVolume, error) + func (k *KubeClient) GetPVByLabel(label string) (*v1.PersistentVolume, error) + func (k *KubeClient) GetPVC(pvcName string) (*v1.PersistentVolumeClaim, error) + func (k *KubeClient) GetPVCByLabel(label string, allNamespaces bool) (*v1.PersistentVolumeClaim, error) + func (k *KubeClient) GetPodByLabel(label string, allNamespaces bool) (*v1.Pod, error) + func (k *KubeClient) GetPodsByLabel(label string, allNamespaces bool) ([]v1.Pod, error) + func (k *KubeClient) GetSecret(secretName string) (*v1.Secret, error) + func (k *KubeClient) GetSecretByLabel(label string, allNamespaces bool) (*v1.Secret, error) + func (k *KubeClient) GetServiceByLabel(label string, allNamespaces bool) (*v1.Service, error) + func (k *KubeClient) GetServicesByLabel(label string, allNamespaces bool) ([]v1.Service, error) + func (k *KubeClient) GetStatefulSetByLabel(label string, allNamespaces bool) (*appsv1.StatefulSet, error) + func (k *KubeClient) GetStatefulSetsByLabel(label string, allNamespaces bool) ([]appsv1.StatefulSet, error) + func (k *KubeClient) Namespace() string + func (k *KubeClient) RemoveFinalizerFromCRD(crdName string) error + func (k *KubeClient) RemoveTridentUserFromOpenShiftSCC(user, scc string) error + func (k *KubeClient) ServerVersion() *utils.Version + func (k *KubeClient) SetNamespace(namespace string) + func (k *KubeClient) UpdateSecret(secret *v1.Secret) (*v1.Secret, error) + func (k *KubeClient) Version() *version.Info + type KubectlClient struct + func (c *KubectlClient) AddFinalizerToCRD(crdName string) error + func (c *KubectlClient) AddTridentUserToOpenShiftSCC(user, scc string) error + func (c *KubectlClient) CLI() string + func (c *KubectlClient) CheckCRDExists(crdName string) (bool, error) + func (c *KubectlClient) CheckConfigMapExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (c *KubectlClient) CheckDaemonSetExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (c *KubectlClient) CheckDeploymentExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (c *KubectlClient) CheckNamespaceExists(namespace string) (bool, error) + func (c *KubectlClient) CheckPVCBound(pvcName string) (bool, error) + func (c *KubectlClient) CheckPVCExists(pvcName string) (bool, error) + func (c *KubectlClient) CheckPVExists(pvName string) (bool, error) + func (c *KubectlClient) CheckPodExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (c *KubectlClient) CheckSecretExists(secretName string) (bool, error) + func (c *KubectlClient) CheckServiceExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (c *KubectlClient) CheckStatefulSetExistsByLabel(label string, allNamespaces bool) (bool, string, error) + func (c *KubectlClient) CreateCHAPSecret(secretName, accountName, initiatorSecret, targetSecret string) (*v1.Secret, error) + func (c *KubectlClient) CreateConfigMapFromDirectory(path, name, label string) error + func (c *KubectlClient) CreateObjectByFile(filePath string) error + func (c *KubectlClient) CreateObjectByYAML(yamlData string) error + func (c *KubectlClient) CreateSecret(secret *v1.Secret) (*v1.Secret, error) + func (c *KubectlClient) DeleteCRD(crdName string) error + func (c *KubectlClient) DeleteConfigMapByLabel(label string) error + func (c *KubectlClient) DeleteDaemonSetByLabel(label string) error + func (c *KubectlClient) DeleteDeploymentByLabel(label string) error + func (c *KubectlClient) DeleteObjectByFile(filePath string, ignoreNotFound bool) error + func (c *KubectlClient) DeleteObjectByYAML(yaml string, ignoreNotFound bool) error + func (c *KubectlClient) DeletePVByLabel(label string) error + func (c *KubectlClient) DeletePVCByLabel(label string) error + func (c *KubectlClient) DeletePodByLabel(label string) error + func (c *KubectlClient) DeleteSecret(secretName string) error + func (c *KubectlClient) DeleteSecretByLabel(label string) error + func (c *KubectlClient) DeleteServiceByLabel(label string) error + func (c *KubectlClient) DeleteStatefulSetByLabel(label string) error + func (c *KubectlClient) Exec(podName, containerName string, commandArgs []string) ([]byte, error) + func (c *KubectlClient) Flavor() OrchestratorFlavor + func (c *KubectlClient) FollowPodLogs(pod, container, namespace string, logLineCallback LogLineCallback) + func (c *KubectlClient) GetCRD(crdName string) (*apiextensionv1beta1.CustomResourceDefinition, error) + func (c *KubectlClient) GetCRDClient() (*crdclient.Clientset, error) + func (c *KubectlClient) GetConfigMapByLabel(label string, allNamespaces bool) (*v1.ConfigMap, error) + func (c *KubectlClient) GetConfigMapsByLabel(label string, allNamespaces bool) ([]v1.ConfigMap, error) + func (c *KubectlClient) GetDaemonSetByLabel(label string, allNamespaces bool) (*appsv1.DaemonSet, error) + func (c *KubectlClient) GetDaemonSetsByLabel(label string, allNamespaces bool) ([]appsv1.DaemonSet, error) + func (c *KubectlClient) GetDeploymentByLabel(label string, allNamespaces bool) (*appsv1.Deployment, error) + func (c *KubectlClient) GetDeploymentsByLabel(label string, allNamespaces bool) ([]appsv1.Deployment, error) + func (c *KubectlClient) GetPV(pvName string) (*v1.PersistentVolume, error) + func (c *KubectlClient) GetPVByLabel(label string) (*v1.PersistentVolume, error) + func (c *KubectlClient) GetPVC(pvcName string) (*v1.PersistentVolumeClaim, error) + func (c *KubectlClient) GetPVCByLabel(label string, allNamespaces bool) (*v1.PersistentVolumeClaim, error) + func (c *KubectlClient) GetPodByLabel(label string, allNamespaces bool) (*v1.Pod, error) + func (c *KubectlClient) GetPodsByLabel(label string, allNamespaces bool) ([]v1.Pod, error) + func (c *KubectlClient) GetSecret(secretName string) (*v1.Secret, error) + func (c *KubectlClient) GetSecretByLabel(label string, allNamespaces bool) (*v1.Secret, error) + func (c *KubectlClient) GetServiceByLabel(label string, allNamespaces bool) (*v1.Service, error) + func (c *KubectlClient) GetServicesByLabel(label string, allNamespaces bool) ([]v1.Service, error) + func (c *KubectlClient) GetStatefulSetByLabel(label string, allNamespaces bool) (*appsv1.StatefulSet, error) + func (c *KubectlClient) GetStatefulSetsByLabel(label string, allNamespaces bool) ([]appsv1.StatefulSet, error) + func (c *KubectlClient) Namespace() string + func (c *KubectlClient) RemoveFinalizerFromCRD(crdName string) error + func (c *KubectlClient) RemoveTridentUserFromOpenShiftSCC(user, scc string) error + func (c *KubectlClient) ServerVersion() *utils.Version + func (c *KubectlClient) SetNamespace(namespace string) + func (c *KubectlClient) UpdateSecret(secret *v1.Secret) (*v1.Secret, error) + func (c *KubectlClient) Version() *version.Info + type LogLineCallback func(string) + type OrchestratorFlavor string + type Version struct + ClientVersion struct{ ... } + OpenshiftVersion string + ServerVersion struct{ ... }