kubernetes

package

Go to main page

Versions in this module

v0

v0.8.0

Feb 14, 2024

Changes in this version

+ const EverestDBNamespacesEnvVar

+ const OLMNamespace

type InstallOperatorRequest

+ SubscriptionConfig *olmv1alpha1.SubscriptionConfig

+ TargetNamespaces []string

type Kubernetes

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

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

+ func (k *Kubernetes) CreateOperatorGroup(ctx context.Context, name, namespace string, targetNamespaces []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) DeleteMonitoringConfig(ctx context.Context, namespace, name string) error

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

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

+ func (k *Kubernetes) GetDBNamespaces(ctx context.Context, namespace string) ([]string, 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) 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) IsBackupStorageUsed(ctx context.Context, namespace, backupStorageName string) (bool, error)

+ func (k *Kubernetes) ListBackupStorages(ctx context.Context, namespace string) (*everestv1alpha1.BackupStorageList, 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) ListDatabaseEngines(ctx context.Context, namespace string) (*everestv1alpha1.DatabaseEngineList, error)

+ func (k *Kubernetes) ListMonitoringConfigs(ctx context.Context, namespace string) (*everestv1alpha1.MonitoringConfigList, 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

v0.7.0

Jan 23, 2024

Changes in this version

+ const EverestOperatorDeploymentName

v0.6.0

Dec 21, 2023

Changes in this version

+ const CatalogSource

+ const CatalogSourceNamespace

+ const OperatorGroup

type Kubernetes

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

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

v0.5.0

Nov 21, 2023

Changes in this version

+ const PerconaEverestDeploymentName

type Kubernetes

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

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

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

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

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

v0.4.1

Nov 17, 2023

v0.4.0

Oct 22, 2023

Changes in this version

type Kubernetes

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

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

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

v0.3.0

Sep 29, 2023

v0.2.0

Sep 7, 2023

Changes in this version

type Kubernetes

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

v0.1.0

Aug 10, 2023

v0.0.3

Aug 8, 2023

v0.0.2

Aug 8, 2023

v0.0.1

Aug 8, 2023

Changes in this version

+ const APIVersionCoreosV1

+ const ClusterTypeEKS

+ const ClusterTypeGeneric

+ const ClusterTypeMinikube

+ const ClusterTypeUnknown

+ const ContainerStateTerminated

+ const ContainerStateWaiting

+ var ErrEmptyVersionTag error = 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

+ type InstallOperatorRequest struct

+ CatalogSource string

+ CatalogSourceNamespace string

+ Channel string

+ InstallPlanApproval v1alpha1.Approval

+ Name string

+ Namespace string

+ OperatorGroup string

+ StartingCSV string

+ type Kubernetes struct

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

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

+ func (k *Kubernetes) ClusterName() string

+ func (k *Kubernetes) CreateClusterRole(namespace, 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) CreateNamespace(name 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) 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) DeleteDatabaseCluster(ctx context.Context, name string) error

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

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

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

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

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

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

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

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

+ func (k *Kubernetes) GetLogs(ctx context.Context, containerStatuses []corev1.ContainerStatus, ...) ([]string, 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, name, namespace 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) InstallOLMOperator(ctx context.Context) error

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

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

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

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

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

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

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

+ func (k *Kubernetes) ProvisionMonitoring(namespace, k8sSecretID, pmmPublicAddress string) error

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

+ func (k *Kubernetes) UpgradeOperator(ctx context.Context, namespace, name 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

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