client

package

Go to main page

Versions in this module

v0

v0.8.0

Feb 22, 2024

Changes in this version

type Client

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

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

type KubeClientConnector

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

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

type MockKubeClientConnector

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

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

v0.7.0

Jan 31, 2024

v0.6.0

Jan 11, 2024

v0.5.0

Nov 28, 2023

Changes in this version

type Client

+ func NewInCluster() (*Client, error)

+ func (c *Client) Config() *rest.Config

+ func (c *Client) ListBackupStorages(ctx context.Context, options metav1.ListOptions) (*everestv1alpha1.BackupStorageList, error)

+ func (c *Client) Namespace() string

+ func (c *Client) UpdateMonitoringConfig(ctx context.Context, config *everestv1alpha1.MonitoringConfig) error

type KubeClientConnector

+ Config func() *rest.Config

+ ListBackupStorages func(ctx context.Context, options metav1.ListOptions) (*everestv1alpha1.BackupStorageList, error)

+ Namespace func() string

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

type MockKubeClientConnector

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

+ func (_m *MockKubeClientConnector) ListBackupStorages(ctx context.Context, options metav1.ListOptions) (*v1alpha1.BackupStorageList, error)

+ func (_m *MockKubeClientConnector) Namespace() string

+ func (_m *MockKubeClientConnector) UpdateMonitoringConfig(ctx context.Context, config *v1alpha1.MonitoringConfig) error

v0.4.1

Nov 17, 2023

v0.4.0

Nov 1, 2023

v0.3.0

Sep 29, 2023

Changes in this version

type Client

+ func (c *Client) GetDatabaseClusterBackup(ctx context.Context, name string) (*everestv1alpha1.DatabaseClusterBackup, error)

+ func (c *Client) GetDatabaseClusterRestore(ctx context.Context, name string) (*everestv1alpha1.DatabaseClusterRestore, error)

+ func (c *Client) GetDatabaseEngine(ctx context.Context, name string) (*everestv1alpha1.DatabaseEngine, error)

+ func (c *Client) ListDatabaseClusterBackups(ctx context.Context) (*everestv1alpha1.DatabaseClusterBackupList, error)

+ func (c *Client) ListDatabaseClusterRestores(ctx context.Context) (*everestv1alpha1.DatabaseClusterRestoreList, error)

+ func (c *Client) ListDatabaseEngines(ctx context.Context) (*everestv1alpha1.DatabaseEngineList, error)

type KubeClientConnector

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

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

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

+ ListDatabaseClusterBackups func(ctx context.Context) (*everestv1alpha1.DatabaseClusterBackupList, error)

+ ListDatabaseClusterRestores func(ctx context.Context) (*everestv1alpha1.DatabaseClusterRestoreList, error)

+ ListDatabaseEngines func(ctx context.Context) (*everestv1alpha1.DatabaseEngineList, error)

type MockKubeClientConnector

+ func (_m *MockKubeClientConnector) GetDatabaseClusterBackup(ctx context.Context, name string) (*v1alpha1.DatabaseClusterBackup, error)

+ func (_m *MockKubeClientConnector) GetDatabaseClusterRestore(ctx context.Context, name string) (*v1alpha1.DatabaseClusterRestore, error)

+ func (_m *MockKubeClientConnector) GetDatabaseEngine(ctx context.Context, name string) (*v1alpha1.DatabaseEngine, error)

+ func (_m *MockKubeClientConnector) ListDatabaseClusterBackups(ctx context.Context) (*v1alpha1.DatabaseClusterBackupList, error)

+ func (_m *MockKubeClientConnector) ListDatabaseClusterRestores(ctx context.Context) (*v1alpha1.DatabaseClusterRestoreList, error)

+ func (_m *MockKubeClientConnector) ListDatabaseEngines(ctx context.Context) (*v1alpha1.DatabaseEngineList, error)

v0.2.0

Sep 6, 2023

Changes in this version

type Client

+ func (c *Client) ApplyObject(obj runtime.Object) error

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

+ func (c *Client) CreateMonitoringConfig(ctx context.Context, mc *everestv1alpha1.MonitoringConfig) error

+ func (c *Client) CreateResource(ctx context.Context, obj runtime.Object, opts *metav1.CreateOptions) error

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

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

+ func (c *Client) DeleteMonitoringConfig(ctx context.Context, name string) error

+ func (c *Client) DeleteObject(obj runtime.Object) error

+ func (c *Client) DeleteResource(ctx context.Context, obj runtime.Object, opts *metav1.DeleteOptions) error

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

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

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

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

+ func (c *Client) GetObject(gvk schema.GroupVersionKind, name string, into runtime.Object) error

+ func (c *Client) GetResource(ctx context.Context, name string, into runtime.Object, opts *metav1.GetOptions) error

+ func (c *Client) ListMonitoringConfigs(ctx context.Context) (*everestv1alpha1.MonitoringConfigList, error)

+ func (c *Client) ListObjects(gvk schema.GroupVersionKind, into runtime.Object) error

+ func (c *Client) ListResources(ctx context.Context, into runtime.Object, opts *metav1.ListOptions) error

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

+ func (c *Client) UpdateResource(ctx context.Context, obj runtime.Object, opts *metav1.UpdateOptions) error

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

type KubeClientConnector

+ ApplyObject func(obj runtime.Object) error

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

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

+ CreateResource func(ctx context.Context, obj runtime.Object, opts *metav1.CreateOptions) error

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

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

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

+ DeleteObject func(obj runtime.Object) error

+ DeleteResource func(ctx context.Context, obj runtime.Object, opts *metav1.DeleteOptions) error

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

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

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

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

+ GetObject func(gvk schema.GroupVersionKind, name string, into runtime.Object) error

+ GetResource func(ctx context.Context, name string, into runtime.Object, opts *metav1.GetOptions) error

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

+ ListObjects func(gvk schema.GroupVersionKind, into runtime.Object) error

+ ListResources func(ctx context.Context, into runtime.Object, opts *metav1.ListOptions) error

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

+ UpdateResource func(ctx context.Context, obj runtime.Object, opts *metav1.UpdateOptions) error

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

type MockKubeClientConnector

+ func NewMockKubeClientConnector(t interface{ ... }) *MockKubeClientConnector

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

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

+ func (_m *MockKubeClientConnector) CreateMonitoringConfig(ctx context.Context, mc *v1alpha1.MonitoringConfig) error

+ func (_m *MockKubeClientConnector) CreateResource(ctx context.Context, obj runtime.Object, opts *v1.CreateOptions) error

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

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

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

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

+ func (_m *MockKubeClientConnector) DeleteResource(ctx context.Context, obj runtime.Object, opts *v1.DeleteOptions) error

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

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

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

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

+ func (_m *MockKubeClientConnector) GetObject(gvk schema.GroupVersionKind, name string, into runtime.Object) error

+ func (_m *MockKubeClientConnector) GetResource(ctx context.Context, name string, into runtime.Object, opts *v1.GetOptions) error

+ func (_m *MockKubeClientConnector) ListMonitoringConfigs(ctx context.Context) (*v1alpha1.MonitoringConfigList, error)

+ func (_m *MockKubeClientConnector) ListObjects(gvk schema.GroupVersionKind, into runtime.Object) error

+ func (_m *MockKubeClientConnector) ListResources(ctx context.Context, into runtime.Object, opts *v1.ListOptions) error

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

+ func (_m *MockKubeClientConnector) UpdateResource(ctx context.Context, obj runtime.Object, opts *v1.UpdateOptions) error

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

v0.1.0

Aug 17, 2023

Changes in this version

+ type Client struct

+ func NewFromKubeConfig(kubeconfig []byte, namespace string) (*Client, error)

+ func (c *Client) ClusterName() string

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

+ func (c *Client) GetNodes(ctx context.Context) (*corev1.NodeList, error)

+ func (c *Client) GetPersistentVolumes(ctx context.Context) (*corev1.PersistentVolumeList, error)

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

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

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

+ func (c *Client) GetStorageClasses(ctx context.Context) (*storagev1.StorageClassList, error)

+ func (c *Client) ListDatabaseClusters(ctx context.Context) (*everestv1alpha1.DatabaseClusterList, error)

+ type KubeClientConnector interface

+ ClusterName func() string

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

+ GetNodes func(ctx context.Context) (*corev1.NodeList, error)

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

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

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

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

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

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

+ type MockKubeClientConnector struct

+ func (_m *MockKubeClientConnector) ClusterName() string

+ func (_m *MockKubeClientConnector) GetDatabaseCluster(ctx context.Context, name string) (*v1alpha1.DatabaseCluster, error)

+ func (_m *MockKubeClientConnector) GetNodes(ctx context.Context) (*v1.NodeList, error)

+ func (_m *MockKubeClientConnector) GetPersistentVolumes(ctx context.Context) (*v1.PersistentVolumeList, error)

+ func (_m *MockKubeClientConnector) GetPods(ctx context.Context, namespace string, labelSelector *metav1.LabelSelector) (*v1.PodList, error)

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

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

+ func (_m *MockKubeClientConnector) GetStorageClasses(ctx context.Context) (*storagev1.StorageClassList, error)

+ func (_m *MockKubeClientConnector) ListDatabaseClusters(ctx context.Context) (*v1alpha1.DatabaseClusterList, error)

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