Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

kubernetes

package

Go to main page

Versions in this module

v0

v0.10.1

May 23, 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.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