kubernetes

package

Go to main page

Versions in this module

v1

v1.4.0-rc1

Dec 5, 2024

v1.3.0

Nov 18, 2024

v1.3.0-rc5

Nov 14, 2024

v1.3.0-rc4

Nov 12, 2024

v1.3.0-rc3

Nov 6, 2024

v1.3.0-rc2

Oct 25, 2024

v1.3.0-rc1

Oct 9, 2024

v1.2.0

Oct 1, 2024

Changes in this version

type Kubernetes

+ func (k *Kubernetes) CSVNameFromOperator(operatorName string, version *goversion.Version) string

+ func (k *Kubernetes) WaitForCSVSucceeded(ctx context.Context, namespace, name string) error

type KubernetesConnector

+ CSVNameFromOperator func(operatorName string, version *goversion.Version) string

+ CreateBackupStorage func(ctx context.Context, storage *everestv1alpha1.BackupStorage) error

+ CreateMonitoringConfig func(ctx context.Context, storage *everestv1alpha1.MonitoringConfig) error

+ DeleteBackupStorage func(ctx context.Context, namespace, name string) error

+ DeleteMonitoringConfig func(ctx context.Context, namespace, name string) error

+ GetBackupStorage func(ctx context.Context, namespace, name string) (*everestv1alpha1.BackupStorage, error)

+ GetMonitoringConfig func(ctx context.Context, namespace, name string) (*everestv1alpha1.MonitoringConfig, error)

+ GetMonitoringConfigsBySecretName func(ctx context.Context, namespace, secretName string) ([]*everestv1alpha1.MonitoringConfig, error)

+ IsBackupStorageUsed func(ctx context.Context, namespace, name string) (bool, error)

+ IsMonitoringConfigUsed func(ctx context.Context, namespace, name string) (bool, error)

+ ListBackupStorages func(ctx context.Context, namespace string) (*everestv1alpha1.BackupStorageList, error)

+ ListMonitoringConfigs func(ctx context.Context, namespace string) (*everestv1alpha1.MonitoringConfigList, error)

+ UpdateBackupStorage func(ctx context.Context, storage *everestv1alpha1.BackupStorage) error

+ UpdateMonitoringConfig func(ctx context.Context, storage *everestv1alpha1.MonitoringConfig) error

+ WaitForCSVSucceeded func(ctx context.Context, namespace, name string) error

type MockKubernetesConnector

+ func (_m *MockKubernetesConnector) CSVNameFromOperator(operatorName string, _a1 *version.Version) string

+ func (_m *MockKubernetesConnector) CreateBackupStorage(ctx context.Context, storage *v1alpha1.BackupStorage) error

+ func (_m *MockKubernetesConnector) CreateMonitoringConfig(ctx context.Context, storage *v1alpha1.MonitoringConfig) error

+ func (_m *MockKubernetesConnector) DeleteBackupStorage(ctx context.Context, namespace string, name string) error

+ func (_m *MockKubernetesConnector) DeleteMonitoringConfig(ctx context.Context, namespace string, name string) error

+ func (_m *MockKubernetesConnector) GetBackupStorage(ctx context.Context, namespace string, name string) (*v1alpha1.BackupStorage, error)

+ func (_m *MockKubernetesConnector) GetMonitoringConfig(ctx context.Context, namespace string, name string) (*v1alpha1.MonitoringConfig, error)

+ func (_m *MockKubernetesConnector) GetMonitoringConfigsBySecretName(ctx context.Context, namespace string, secretName string) ([]*v1alpha1.MonitoringConfig, error)

+ func (_m *MockKubernetesConnector) IsBackupStorageUsed(ctx context.Context, namespace string, name string) (bool, error)

+ func (_m *MockKubernetesConnector) IsMonitoringConfigUsed(ctx context.Context, namespace string, name string) (bool, error)

+ func (_m *MockKubernetesConnector) ListBackupStorages(ctx context.Context, namespace string) (*v1alpha1.BackupStorageList, error)

+ func (_m *MockKubernetesConnector) ListMonitoringConfigs(ctx context.Context, namespace string) (*v1alpha1.MonitoringConfigList, error)

+ func (_m *MockKubernetesConnector) UpdateBackupStorage(ctx context.Context, storage *v1alpha1.BackupStorage) error

+ func (_m *MockKubernetesConnector) UpdateMonitoringConfig(ctx context.Context, storage *v1alpha1.MonitoringConfig) error

+ func (_m *MockKubernetesConnector) WaitForCSVSucceeded(ctx context.Context, namespace string, name string) error

v1.2.0-rc8

Sep 30, 2024

v1.2.0-rc7

Sep 26, 2024

v1.2.0-rc6

Sep 19, 2024

v1.2.0-rc5

Sep 19, 2024

v1.2.0-rc4

Sep 18, 2024

v1.2.0-rc3

Sep 17, 2024

v1.2.0-rc2

Sep 11, 2024

v1.2.0-rc1

Aug 30, 2024

v1.1.1

Aug 22, 2024

v1.1.1-rc1

Aug 19, 2024

v1.1.0

Aug 12, 2024

Changes in this version

type Kubernetes

+ func (k *Kubernetes) GetConfigMap(ctx context.Context, name, namespace string) (*corev1.ConfigMap, error)

type KubernetesConnector

+ GetConfigMap func(ctx context.Context, name, namespace string) (*corev1.ConfigMap, error)

type MockKubernetesConnector

+ func (_m *MockKubernetesConnector) GetConfigMap(ctx context.Context, name string, namespace string) (*v1.ConfigMap, error)

v1.1.0-rc3

Aug 8, 2024

v1.1.0-rc2

Aug 6, 2024

v1.1.0-rc1

Jul 30, 2024

v1.0.1

Jul 8, 2024

v1.0.0

Jun 28, 2024

Changes in this version

type Kubernetes

+ func (c *Kubernetes) Accounts() accounts.Interface

+ func (k *Kubernetes) CreateRSAKeyPair(ctx context.Context) error

+ func (k *Kubernetes) GetEverestSettings(ctx context.Context) (common.EverestSettings, error)

+ func (k *Kubernetes) ListNamespaces(ctx context.Context, opts metav1.ListOptions) (*corev1.NamespaceList, error)

+ func (k *Kubernetes) RestartDeployment(ctx context.Context, name, namespace string) error

+ func (k *Kubernetes) RestartOperator(ctx context.Context, name, namespace string) error

+ func (k *Kubernetes) SetDatabaseEngineLock(ctx context.Context, namespace, name string, locked bool) error

+ func (k *Kubernetes) UpdateClusterServiceVersion(ctx context.Context, csv *olmv1alpha1.ClusterServiceVersion) (*olmv1alpha1.ClusterServiceVersion, error)

+ func (k *Kubernetes) UpdateDeployment(ctx context.Context, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

+ func (k *Kubernetes) UpdateEverestSettings(ctx context.Context, settings common.EverestSettings) error

+ func (k *Kubernetes) UpdateNamespace(ctx context.Context, namespace *corev1.Namespace, opts metav1.UpdateOptions) (*corev1.Namespace, error)

+ func (k *Kubernetes) WithClient(c client.KubeClientConnector) *Kubernetes

type KubernetesConnector

+ Accounts func() accounts.Interface

+ CreateRSAKeyPair func(ctx context.Context) error

+ CreateSecret func(ctx context.Context, secret *corev1.Secret) (*corev1.Secret, error)

+ DeleteNamespace func(ctx context.Context, name string) error

+ DeleteSecret func(ctx context.Context, namespace, name string) error

+ GetEverestSettings func(ctx context.Context) (common.EverestSettings, error)

+ GetNamespace func(ctx context.Context, name string) (*corev1.Namespace, error)

+ GetSecret func(ctx context.Context, namespace, name string) (*corev1.Secret, error)

+ ListNamespaces func(ctx context.Context, opts metav1.ListOptions) (*corev1.NamespaceList, error)

+ ListSecrets func(ctx context.Context, namespace string) (*corev1.SecretList, error)

+ RestartDeployment func(ctx context.Context, name, namespace string) error

+ RestartOperator func(ctx context.Context, name, namespace string) error

+ SetSecret func(secret *corev1.Secret) error

+ UpdateClusterServiceVersion func(ctx context.Context, csv *olmv1alpha1.ClusterServiceVersion) (*olmv1alpha1.ClusterServiceVersion, error)

+ UpdateDeployment func(ctx context.Context, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

+ UpdateEverestSettings func(ctx context.Context, settings common.EverestSettings) error

+ UpdateNamespace func(ctx context.Context, namespace *corev1.Namespace, opts metav1.UpdateOptions) (*corev1.Namespace, error)

+ UpdateSecret func(ctx context.Context, secret *corev1.Secret) (*corev1.Secret, error)

+ WithClient func(c client.KubeClientConnector) *Kubernetes

type MockKubernetesConnector

+ func (_m *MockKubernetesConnector) Accounts() accounts.Interface

+ func (_m *MockKubernetesConnector) CreateRSAKeyPair(ctx context.Context) error

+ func (_m *MockKubernetesConnector) CreateSecret(ctx context.Context, secret *v1.Secret) (*v1.Secret, error)

+ func (_m *MockKubernetesConnector) DeleteNamespace(ctx context.Context, name string) error

+ func (_m *MockKubernetesConnector) DeleteSecret(ctx context.Context, namespace string, name string) error

+ func (_m *MockKubernetesConnector) GetEverestSettings(ctx context.Context) (common.EverestSettings, error)

+ func (_m *MockKubernetesConnector) GetNamespace(ctx context.Context, name string) (*v1.Namespace, error)

+ func (_m *MockKubernetesConnector) GetSecret(ctx context.Context, namespace string, name string) (*v1.Secret, error)

+ func (_m *MockKubernetesConnector) ListNamespaces(ctx context.Context, opts metav1.ListOptions) (*v1.NamespaceList, error)

+ func (_m *MockKubernetesConnector) ListSecrets(ctx context.Context, namespace string) (*v1.SecretList, error)

+ func (_m *MockKubernetesConnector) RestartDeployment(ctx context.Context, name string, namespace string) error

+ func (_m *MockKubernetesConnector) RestartOperator(ctx context.Context, name string, namespace string) error

+ func (_m *MockKubernetesConnector) SetSecret(secret *v1.Secret) error

+ func (_m *MockKubernetesConnector) UpdateClusterServiceVersion(ctx context.Context, csv *operatorsv1alpha1.ClusterServiceVersion) (*operatorsv1alpha1.ClusterServiceVersion, error)

+ func (_m *MockKubernetesConnector) UpdateDeployment(ctx context.Context, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

+ func (_m *MockKubernetesConnector) UpdateEverestSettings(ctx context.Context, settings common.EverestSettings) error

+ func (_m *MockKubernetesConnector) UpdateNamespace(ctx context.Context, namespace *v1.Namespace, opts metav1.UpdateOptions) (*v1.Namespace, error)

+ func (_m *MockKubernetesConnector) UpdateSecret(ctx context.Context, secret *v1.Secret) (*v1.Secret, error)

+ func (_m *MockKubernetesConnector) WithClient(c kubernetesclient.KubeClientConnector) *Kubernetes

v1.0.0-rc6

Jun 28, 2024

v1.0.0-rc5

Jun 27, 2024

v1.0.0-rc4

Jun 27, 2024

v1.0.0-rc3

Jun 26, 2024

v1.0.0-rc2

Jun 19, 2024

v1.0.0-rc1

Jun 14, 2024

v0

v0.11.0-rc1

Jun 4, 2024

v0.10.1

May 23, 2024

v0.10.1-rc1

May 15, 2024

v0.10.0

May 3, 2024

Changes in this version

+ var ErrOperatorNotInstalled = fmt.Errorf("operatorNotInstalled")

type Kubernetes

+ func (k *Kubernetes) ApproveInstallPlan(ctx context.Context, namespace, installPlanName string) (bool, error)

+ func (k *Kubernetes) OperatorInstalledVersion(ctx context.Context, namespace, name string) (*goversion.Version, error)

+ func (k *Kubernetes) UpdateDatabaseClusterBackup(ctx context.Context, backup *everestv1alpha1.DatabaseClusterBackup) (*everestv1alpha1.DatabaseClusterBackup, error)

+ func (k *Kubernetes) UpdateDatabaseEngine(ctx context.Context, namespace string, engine *everestv1alpha1.DatabaseEngine) (*everestv1alpha1.DatabaseEngine, error)

+ func (k *Kubernetes) WaitForInstallPlan(ctx context.Context, namespace, operatorName string, ...) (*olmv1alpha1.InstallPlan, error)

+ func (k *Kubernetes) WaitForInstallPlanCompleted(ctx context.Context, namespace, name string) error

+ type KubernetesConnector interface

+ ApplyObject func(obj runtime.Object) error

+ ApproveInstallPlan func(ctx context.Context, namespace, installPlanName string) (bool, error)

+ ClusterName func() string

+ Config func() *rest.Config

+ CreateNamespace func(name string) error

+ CreateOperatorGroup func(ctx context.Context, name, namespace string, targetNamespaces []string) error

+ CreatePMMSecret func(namespace, secretName string, secrets map[string][]byte) error

+ CreateRestore func(restore *everestv1alpha1.DatabaseClusterRestore) error

+ DeleteClusterServiceVersion func(ctx context.Context, key types.NamespacedName) error

+ DeleteEverest func(ctx context.Context, namespace string, version *goversion.Version) error

+ DeleteObject func(obj runtime.Object) error

+ GetClusterServiceVersion func(ctx context.Context, key types.NamespacedName) (*olmv1alpha1.ClusterServiceVersion, error)

+ GetClusterType func(ctx context.Context) (ClusterType, error)

+ GetDBNamespaces func(ctx context.Context, namespace string) ([]string, error)

+ GetDBaaSOperatorVersion func(ctx context.Context) (string, error)

+ GetDefaultStorageClassName func(ctx context.Context) (string, error)

+ GetDeployment func(ctx context.Context, name, namespace string) (*appsv1.Deployment, error)

+ GetEvents func(ctx context.Context, pod string) ([]string, error)

+ GetEverestID func(ctx context.Context) (string, error)

+ GetLogs func(ctx context.Context, containerStatuses []corev1.ContainerStatus, ...) ([]string, error)

+ GetPSMDBOperatorVersion func(ctx context.Context) (string, error)

+ GetPXCOperatorVersion func(ctx context.Context) (string, error)

+ GetServerVersion func() (*version.Info, error)

+ InstallEverest func(ctx context.Context, namespace string, version *goversion.Version) error

+ InstallOLMOperator func(ctx context.Context, upgrade bool) error

+ InstallOperator func(ctx context.Context, req InstallOperatorRequest) error

+ InstallPerconaCatalog func(ctx context.Context, version *goversion.Version) error

+ ListClusterServiceVersion func(ctx context.Context, namespace string) (*olmv1alpha1.ClusterServiceVersionList, error)

+ ListEngineDeploymentNames func(ctx context.Context, namespace string) ([]string, error)

+ ListSubscriptions func(ctx context.Context, namespace string) (*olmv1alpha1.SubscriptionList, error)

+ Namespace func() string

+ OperatorInstalledVersion func(ctx context.Context, namespace, name string) (*goversion.Version, error)

+ ProvisionMonitoring func(namespace string) error

+ RestartEverest func(ctx context.Context, name, namespace string) error

+ UpdateClusterRoleBinding func(ctx context.Context, name string, namespaces []string) error

+ UpgradeOperator func(ctx context.Context, namespace, name string) error

+ WaitForInstallPlan func(ctx context.Context, namespace, operatorName string, ...) (*olmv1alpha1.InstallPlan, error)

+ WaitForInstallPlanCompleted func(ctx context.Context, namespace, name string) error

+ WaitForRollout func(ctx context.Context, name, namespace string) error

+ type MockKubernetesConnector struct

+ func NewMockKubernetesConnector(t interface{ ... }) *MockKubernetesConnector

+ func (_m *MockKubernetesConnector) ApplyObject(obj runtime.Object) error

+ func (_m *MockKubernetesConnector) ApproveInstallPlan(ctx context.Context, namespace string, installPlanName string) (bool, error)

+ func (_m *MockKubernetesConnector) ClusterName() string

+ func (_m *MockKubernetesConnector) Config() *rest.Config

+ func (_m *MockKubernetesConnector) CreateNamespace(name string) error

+ func (_m *MockKubernetesConnector) CreateOperatorGroup(ctx context.Context, name string, namespace string, targetNamespaces []string) error

+ func (_m *MockKubernetesConnector) CreatePMMSecret(namespace string, secretName string, secrets map[string][]byte) error

+ func (_m *MockKubernetesConnector) CreateRestore(restore *v1alpha1.DatabaseClusterRestore) error

+ func (_m *MockKubernetesConnector) DeleteClusterServiceVersion(ctx context.Context, key types.NamespacedName) error

+ func (_m *MockKubernetesConnector) DeleteEverest(ctx context.Context, namespace string, _a2 *version.Version) error

+ func (_m *MockKubernetesConnector) DeleteObject(obj runtime.Object) error

+ func (_m *MockKubernetesConnector) GetClusterServiceVersion(ctx context.Context, key types.NamespacedName) (*operatorsv1alpha1.ClusterServiceVersion, error)

+ func (_m *MockKubernetesConnector) GetClusterType(ctx context.Context) (ClusterType, error)

+ func (_m *MockKubernetesConnector) GetDBNamespaces(ctx context.Context, namespace string) ([]string, error)

+ func (_m *MockKubernetesConnector) GetDBaaSOperatorVersion(ctx context.Context) (string, error)

+ func (_m *MockKubernetesConnector) GetDefaultStorageClassName(ctx context.Context) (string, error)

+ func (_m *MockKubernetesConnector) GetDeployment(ctx context.Context, name string, namespace string) (*v1.Deployment, error)

+ func (_m *MockKubernetesConnector) GetEvents(ctx context.Context, pod string) ([]string, error)

+ func (_m *MockKubernetesConnector) GetEverestID(ctx context.Context) (string, error)

+ func (_m *MockKubernetesConnector) GetLogs(ctx context.Context, containerStatuses []corev1.ContainerStatus, pod string, ...) ([]string, error)

+ func (_m *MockKubernetesConnector) GetPSMDBOperatorVersion(ctx context.Context) (string, error)

+ func (_m *MockKubernetesConnector) GetPXCOperatorVersion(ctx context.Context) (string, error)

+ func (_m *MockKubernetesConnector) GetServerVersion() (*pkgversion.Info, error)

+ func (_m *MockKubernetesConnector) InstallEverest(ctx context.Context, namespace string, _a2 *version.Version) error

+ func (_m *MockKubernetesConnector) InstallOLMOperator(ctx context.Context, upgrade bool) error

+ func (_m *MockKubernetesConnector) InstallOperator(ctx context.Context, req InstallOperatorRequest) error

+ func (_m *MockKubernetesConnector) InstallPerconaCatalog(ctx context.Context, _a1 *version.Version) error

+ func (_m *MockKubernetesConnector) ListClusterServiceVersion(ctx context.Context, namespace string) (*operatorsv1alpha1.ClusterServiceVersionList, error)

+ func (_m *MockKubernetesConnector) ListEngineDeploymentNames(ctx context.Context, namespace string) ([]string, error)

+ func (_m *MockKubernetesConnector) ListSubscriptions(ctx context.Context, namespace string) (*operatorsv1alpha1.SubscriptionList, error)

+ func (_m *MockKubernetesConnector) Namespace() string

+ func (_m *MockKubernetesConnector) OperatorInstalledVersion(ctx context.Context, namespace string, name string) (*version.Version, error)

+ func (_m *MockKubernetesConnector) ProvisionMonitoring(namespace string) error

+ func (_m *MockKubernetesConnector) RestartEverest(ctx context.Context, name string, namespace string) error

+ func (_m *MockKubernetesConnector) UpdateClusterRoleBinding(ctx context.Context, name string, namespaces []string) error

+ func (_m *MockKubernetesConnector) UpgradeOperator(ctx context.Context, namespace string, name string) error

+ func (_m *MockKubernetesConnector) WaitForInstallPlan(ctx context.Context, namespace string, operatorName string, ...) (*operatorsv1alpha1.InstallPlan, error)

+ func (_m *MockKubernetesConnector) WaitForInstallPlanCompleted(ctx context.Context, namespace string, name string) error

+ func (_m *MockKubernetesConnector) WaitForRollout(ctx context.Context, name string, namespace string) error

v0.10.0-rc6

May 3, 2024

v0.10.0-rc5

May 1, 2024

v0.10.0-rc4

Apr 26, 2024

v0.10.0-rc3

Apr 22, 2024

v0.10.0-rc2

Apr 17, 2024

v0.10.0-rc1

Apr 16, 2024

v0.9.1

Apr 2, 2024

v0.9.0

Apr 1, 2024

Changes in this version

+ const APIVersionCoreosV1

+ const ClusterTypeEKS

+ const ClusterTypeGeneric

+ const ClusterTypeMinikube

+ const ClusterTypeUnknown

+ const EverestDBNamespacesEnvVar

+ const EverestOperatorDeploymentName

+ const OLMNamespace

+ const PerconaEverestDeploymentName

+ var ErrEmptyVersionTag = errors.New("got an empty version tag from Github")

+ func IsContainerInState(containerStatuses []corev1.ContainerStatus, state ContainerState) bool

+ func IsNodeInCondition(node corev1.Node, conditionType corev1.NodeConditionType) bool

+ type ClusterType string

+ type ContainerState string

+ const ContainerStateTerminated

+ const ContainerStateWaiting

+ type InstallOperatorRequest struct

+ CatalogSource string

+ CatalogSourceNamespace string

+ Channel string

+ InstallPlanApproval olmv1alpha1.Approval

+ Name string

+ Namespace string

+ OperatorGroup string

+ StartingCSV string

+ SubscriptionConfig *olmv1alpha1.SubscriptionConfig

+ TargetNamespaces []string

+ type Kubernetes struct

+ func New(kubeconfigPath string, l *zap.SugaredLogger) (*Kubernetes, error)

+ func NewEmpty(l *zap.SugaredLogger) *Kubernetes

+ func NewInCluster(l *zap.SugaredLogger) (*Kubernetes, error)

+ func (k *Kubernetes) ApplyObject(obj runtime.Object) error

+ func (k *Kubernetes) ClusterName() string

+ func (k *Kubernetes) Config() *rest.Config

+ func (k *Kubernetes) CreateBackupStorage(ctx context.Context, storage *everestv1alpha1.BackupStorage) error

+ func (k *Kubernetes) CreateClusterRole(name string, rules []rbac.PolicyRule) error

+ func (k *Kubernetes) CreateClusterRoleBinding(namespace, name, roleName, serviceAccountName string) error

+ func (k *Kubernetes) CreateDatabaseCluster(cluster *everestv1alpha1.DatabaseCluster) error

+ func (k *Kubernetes) CreateMonitoringConfig(ctx context.Context, storage *everestv1alpha1.MonitoringConfig) error

+ func (k *Kubernetes) CreateNamespace(name string) error

+ func (k *Kubernetes) CreateOperatorGroup(ctx context.Context, name, namespace string, targetNamespaces []string) error

+ func (k *Kubernetes) CreatePMMSecret(namespace, secretName string, secrets map[string][]byte) error

+ func (k *Kubernetes) CreateRestore(restore *everestv1alpha1.DatabaseClusterRestore) error

+ func (k *Kubernetes) CreateRole(namespace, name string, rules []rbac.PolicyRule) error

+ func (k *Kubernetes) CreateRoleBinding(namespace, name, roleName, serviceAccountName string) error

+ func (k *Kubernetes) CreateSecret(ctx context.Context, secret *corev1.Secret) (*corev1.Secret, error)

+ func (k *Kubernetes) CreateServiceAccount(name, namespace string) error

+ func (k *Kubernetes) CreateServiceAccountToken(serviceAccountName, secretName, namespace string) error

+ func (k *Kubernetes) DeleteAllMonitoringResources(ctx context.Context, namespace string) error

+ func (k *Kubernetes) DeleteBackupStorage(ctx context.Context, namespace, name string) error

+ func (k *Kubernetes) DeleteClusterServiceVersion(ctx context.Context, key types.NamespacedName) error

+ func (k *Kubernetes) DeleteDatabaseCluster(ctx context.Context, namespace, name string) error

+ func (k *Kubernetes) DeleteEverest(_ context.Context, namespace string) error

+ func (k *Kubernetes) DeleteMonitoringConfig(ctx context.Context, namespace, name string) error

+ func (k *Kubernetes) DeleteNamespace(ctx context.Context, name string) error

+ func (k *Kubernetes) DeleteObject(obj runtime.Object) error

+ func (k *Kubernetes) DeleteSecret(ctx context.Context, namespace, name string) error

+ func (k *Kubernetes) GenerateKubeConfigWithToken(user string, secret *corev1.Secret) (string, error)

+ func (k *Kubernetes) GetAllClusterResources(ctx context.Context, clusterType ClusterType, ...) (uint64, uint64, uint64, error)

+ func (k *Kubernetes) GetBackupStorage(ctx context.Context, namespace, name string) (*everestv1alpha1.BackupStorage, error)

+ func (k *Kubernetes) GetClusterServiceVersion(ctx context.Context, key types.NamespacedName) (*olmv1alpha1.ClusterServiceVersion, error)

+ func (k *Kubernetes) GetClusterType(ctx context.Context) (ClusterType, error)

+ func (k *Kubernetes) GetConsumedCPUAndMemory(ctx context.Context, namespace string) (cpuMillis uint64, memoryBytes uint64, err error)

+ func (k *Kubernetes) GetConsumedDiskBytes(_ context.Context, clusterType ClusterType, ...) (uint64, error)

+ func (k *Kubernetes) GetDBNamespaces(ctx context.Context, namespace string) ([]string, error)

+ func (k *Kubernetes) GetDBaaSOperatorVersion(ctx context.Context) (string, error)

+ func (k *Kubernetes) GetDatabaseCluster(ctx context.Context, namespace, name string) (*everestv1alpha1.DatabaseCluster, error)

+ func (k *Kubernetes) GetDatabaseClusterBackup(ctx context.Context, namespace, name string) (*everestv1alpha1.DatabaseClusterBackup, error)

+ func (k *Kubernetes) GetDatabaseClusterRestore(ctx context.Context, namespace, name string) (*everestv1alpha1.DatabaseClusterRestore, error)

+ func (k *Kubernetes) GetDatabaseEngine(ctx context.Context, namespace, name string) (*everestv1alpha1.DatabaseEngine, error)

+ func (k *Kubernetes) GetDefaultStorageClassName(ctx context.Context) (string, error)

+ func (k *Kubernetes) GetDeployment(ctx context.Context, name, namespace string) (*appsv1.Deployment, error)

+ func (k *Kubernetes) GetEvents(ctx context.Context, pod string) ([]string, error)

+ func (k *Kubernetes) GetEverestID(ctx context.Context) (string, error)

+ func (k *Kubernetes) GetLogs(ctx context.Context, containerStatuses []corev1.ContainerStatus, ...) ([]string, error)

+ func (k *Kubernetes) GetMonitoringConfig(ctx context.Context, namespace, name string) (*everestv1alpha1.MonitoringConfig, error)

+ func (k *Kubernetes) GetMonitoringConfigsBySecretName(ctx context.Context, namespace, secretName string) ([]*everestv1alpha1.MonitoringConfig, error)

+ func (k *Kubernetes) GetNamespace(ctx context.Context, name string) (*corev1.Namespace, error)

+ func (k *Kubernetes) GetPSMDBOperatorVersion(ctx context.Context) (string, error)

+ func (k *Kubernetes) GetPXCOperatorVersion(ctx context.Context) (string, error)

+ func (k *Kubernetes) GetPersistentVolumes(ctx context.Context) (*corev1.PersistentVolumeList, error)

+ func (k *Kubernetes) GetPods(ctx context.Context, namespace string, labelSelector *metav1.LabelSelector) (*corev1.PodList, error)

+ func (k *Kubernetes) GetSecret(ctx context.Context, namespace, name string) (*corev1.Secret, error)

+ func (k *Kubernetes) GetServerVersion() (*version.Info, error)

+ func (k *Kubernetes) GetStorageClasses(ctx context.Context) (*storagev1.StorageClassList, error)

+ func (k *Kubernetes) GetWorkerNodes(ctx context.Context) ([]corev1.Node, error)

+ func (k *Kubernetes) InstallEverest(ctx context.Context, namespace string) error

+ func (k *Kubernetes) InstallOLMOperator(ctx context.Context, upgrade bool) error

+ func (k *Kubernetes) InstallOperator(ctx context.Context, req InstallOperatorRequest) error

+ func (k *Kubernetes) InstallPerconaCatalog(ctx context.Context) error

+ func (k *Kubernetes) IsBackupStorageUsed(ctx context.Context, namespace, backupStorageName string) (bool, error)

+ func (k *Kubernetes) IsMonitoringConfigUsed(ctx context.Context, namespace, monitoringConfigName string) (bool, error)

+ func (k *Kubernetes) ListBackupStorages(ctx context.Context, namespace string) (*everestv1alpha1.BackupStorageList, error)

+ func (k *Kubernetes) ListClusterServiceVersion(ctx context.Context, namespace string) (*olmv1alpha1.ClusterServiceVersionList, error)

+ func (k *Kubernetes) ListDatabaseClusterBackups(ctx context.Context, namespace string, options metav1.ListOptions) (*everestv1alpha1.DatabaseClusterBackupList, error)

+ func (k *Kubernetes) ListDatabaseClusterRestores(ctx context.Context, namespace string, options metav1.ListOptions) (*everestv1alpha1.DatabaseClusterRestoreList, error)

+ func (k *Kubernetes) ListDatabaseClusters(ctx context.Context, namespace string) (*everestv1alpha1.DatabaseClusterList, error)

+ func (k *Kubernetes) ListDatabaseEngines(ctx context.Context, namespace string) (*everestv1alpha1.DatabaseEngineList, error)

+ func (k *Kubernetes) ListEngineDeploymentNames(ctx context.Context, namespace string) ([]string, error)

+ func (k *Kubernetes) ListMonitoringConfigs(ctx context.Context, namespace string) (*everestv1alpha1.MonitoringConfigList, error)

+ func (k *Kubernetes) ListSecrets(ctx context.Context, namespace string) (*corev1.SecretList, error)

+ func (k *Kubernetes) ListSubscriptions(ctx context.Context, namespace string) (*olmv1alpha1.SubscriptionList, error)

+ func (k *Kubernetes) Namespace() string

+ func (k *Kubernetes) PatchDatabaseCluster(cluster *everestv1alpha1.DatabaseCluster) error

+ func (k *Kubernetes) ProvisionMonitoring(namespace string) error

+ func (k *Kubernetes) RestartEverest(ctx context.Context, name, namespace string) error

+ func (k *Kubernetes) SetSecret(secret *corev1.Secret) error

+ func (k *Kubernetes) UpdateBackupStorage(ctx context.Context, storage *everestv1alpha1.BackupStorage) error

+ func (k *Kubernetes) UpdateClusterRoleBinding(ctx context.Context, name string, namespaces []string) error

+ func (k *Kubernetes) UpdateMonitoringConfig(ctx context.Context, storage *everestv1alpha1.MonitoringConfig) error

+ func (k *Kubernetes) UpdateSecret(ctx context.Context, secret *corev1.Secret) (*corev1.Secret, error)

+ func (k *Kubernetes) UpgradeOperator(ctx context.Context, namespace, name string) error

+ func (k *Kubernetes) WaitForRollout(ctx context.Context, name, namespace string) error

+ type NodeFileSystemSummary struct

+ UsedBytes uint64

+ type NodeSummary struct

+ Node NodeSummaryNode

+ type NodeSummaryNode struct

+ FileSystem NodeFileSystemSummary

+ type OperatorServiceManager interface

+ InstallOLMOperator func(ctx context.Context) error

+ InstallOperator func(ctx context.Context, req InstallOperatorRequest) error

+ ListSubscriptions func(ctx context.Context, namespace string) (*v1alpha1.SubscriptionList, error)

+ SetKubeConfig func(kubeConfig string) error

+ UpgradeOperator func(ctx context.Context, namespace, name string) error

v0.9.0-rc2

Mar 28, 2024

v0.9.0-rc1

Mar 21, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL