service

package

v0.0.0-...-0227cab Latest Latest Go to latest Published: Jan 9, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/alauda/redis-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func AddBackupAnnotationsAndLabels(instance *databasesv1.RedisFailover, backup *redisbackupv1.RedisBackup) error
type RedisBackupClient
type RedisBackupKubeClient
- func NewRedisBackupKubeClient(k8sService k8s.ClientSet, logger logr.Logger) *RedisBackupKubeClient

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddBackupAnnotationsAndLabels ¶

func AddBackupAnnotationsAndLabels(instance *databasesv1.RedisFailover, backup *redisbackupv1.RedisBackup) error

Types ¶

type RedisBackupClient ¶

type RedisBackupClient interface {
	EnsureStorageReady(ctx context.Context, backup *redisbackupv1.RedisBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error
	EnsureBackupJobCreated(ctx context.Context, backup *redisbackupv1.RedisBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error
	EnsureBackupCompleted(ctx context.Context, backup *redisbackupv1.RedisBackup) error
	UpdateBackup(ctx context.Context, backup *redisbackupv1.RedisBackup) error
	UpdateBackupStatus(ctx context.Context, backup *redisbackupv1.RedisBackup) error
	EnsureRoleReady(ctx context.Context, backup *redisbackupv1.RedisBackup) error
	EnsureInfoAnnotationsAndLabels(ctx context.Context, backup *redisbackupv1.RedisBackup) error
	EnsureInfoAnnotationsAndLabelsForCluster(ctx context.Context, backup *redisbackupv1.RedisBackup) error
}

RedisBackupClient has the minimumm methods that a Redis backup controller needs to satisfy in order to talk with K8s

type RedisBackupKubeClient ¶

type RedisBackupKubeClient struct {
	K8SService k8s.ClientSet
	// contains filtered or unexported fields
}

RedisBackupKubeClient implements the required methods to talk with kubernetes

func NewRedisBackupKubeClient ¶

func NewRedisBackupKubeClient(k8sService k8s.ClientSet, logger logr.Logger) *RedisBackupKubeClient

NewRedisBackupKubeClient creates a new RedisFailoverKubeClient

func (*RedisBackupKubeClient) EnsureBackupCompleted ¶

func (r *RedisBackupKubeClient) EnsureBackupCompleted(ctx context.Context, backup *redisbackupv1.RedisBackup) error

func (*RedisBackupKubeClient) EnsureBackupJobCreated ¶

func (r *RedisBackupKubeClient) EnsureBackupJobCreated(ctx context.Context, backup *redisbackupv1.RedisBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error

func (*RedisBackupKubeClient) EnsureInfoAnnotationsAndLabels ¶

func (r *RedisBackupKubeClient) EnsureInfoAnnotationsAndLabels(ctx context.Context, backup *redisbackupv1.RedisBackup) error

func (*RedisBackupKubeClient) EnsureInfoAnnotationsAndLabelsForCluster ¶

func (r *RedisBackupKubeClient) EnsureInfoAnnotationsAndLabelsForCluster(ctx context.Context, backup *redisbackupv1.RedisBackup) error

func (*RedisBackupKubeClient) EnsureRoleReady ¶

func (r *RedisBackupKubeClient) EnsureRoleReady(ctx context.Context, backup *redisbackupv1.RedisBackup) error

func (*RedisBackupKubeClient) EnsureStorageReady ¶

func (r *RedisBackupKubeClient) EnsureStorageReady(ctx context.Context, backup *redisbackupv1.RedisBackup, labels map[string]string, ownerRefs []metav1.OwnerReference) error

func (*RedisBackupKubeClient) UpdateBackup ¶

func (r *RedisBackupKubeClient) UpdateBackup(ctx context.Context, backup *redisbackupv1.RedisBackup) error

func (*RedisBackupKubeClient) UpdateBackupStatus ¶

func (r *RedisBackupKubeClient) UpdateBackupStatus(ctx context.Context, backup *redisbackupv1.RedisBackup) error

Source Files ¶

View all Source files

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