Documentation ¶
Index ¶
- type RedisClusterBackupClient
- type RedisClusterBackupKubeClient
- func (r *RedisClusterBackupKubeClient) EnsureBackupCompleted(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
- func (r *RedisClusterBackupKubeClient) EnsureBackupJobCreated(ctx context.Context, backup *redisbackupv1.RedisClusterBackup, ...) error
- func (r *RedisClusterBackupKubeClient) EnsureInfoAnnotationsAndLabels(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
- func (r *RedisClusterBackupKubeClient) EnsureRoleReady(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
- func (r *RedisClusterBackupKubeClient) EnsureStorageReady(ctx context.Context, backup *redisbackupv1.RedisClusterBackup, ...) error
- func (r *RedisClusterBackupKubeClient) UpdateBackup(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
- func (r *RedisClusterBackupKubeClient) UpdateBackupStatus(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisClusterBackupClient ¶
type RedisClusterBackupClient interface { EnsureInfoAnnotationsAndLabels(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error EnsureStorageReady(ctx context.Context, backup *redisbackupv1.RedisClusterBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error EnsureBackupJobCreated(ctx context.Context, backup *redisbackupv1.RedisClusterBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error EnsureBackupCompleted(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error UpdateBackup(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error UpdateBackupStatus(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error EnsureRoleReady(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error }
type RedisClusterBackupKubeClient ¶
type RedisClusterBackupKubeClient struct { K8SService k8s.ClientSet // contains filtered or unexported fields }
func NewRedisClusterBackupKubeClient ¶
func NewRedisClusterBackupKubeClient(k8sService k8s.ClientSet, logger logr.Logger) *RedisClusterBackupKubeClient
func (*RedisClusterBackupKubeClient) EnsureBackupCompleted ¶
func (r *RedisClusterBackupKubeClient) EnsureBackupCompleted(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
func (*RedisClusterBackupKubeClient) EnsureBackupJobCreated ¶
func (r *RedisClusterBackupKubeClient) EnsureBackupJobCreated(ctx context.Context, backup *redisbackupv1.RedisClusterBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error
func (*RedisClusterBackupKubeClient) EnsureInfoAnnotationsAndLabels ¶
func (r *RedisClusterBackupKubeClient) EnsureInfoAnnotationsAndLabels(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
func (*RedisClusterBackupKubeClient) EnsureRoleReady ¶
func (r *RedisClusterBackupKubeClient) EnsureRoleReady(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
func (*RedisClusterBackupKubeClient) EnsureStorageReady ¶
func (r *RedisClusterBackupKubeClient) EnsureStorageReady(ctx context.Context, backup *redisbackupv1.RedisClusterBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error
func (*RedisClusterBackupKubeClient) UpdateBackup ¶
func (r *RedisClusterBackupKubeClient) UpdateBackup(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
func (*RedisClusterBackupKubeClient) UpdateBackupStatus ¶
func (r *RedisClusterBackupKubeClient) UpdateBackupStatus(ctx context.Context, backup *redisbackupv1.RedisClusterBackup) error
Click to show internal directories.
Click to hide internal directories.