redisfailover

Documentation

Index

• type RedisFailoverHandler
  • func (r *RedisFailoverHandler) CheckAndHeal(rf *middlev1alpha1.RedisFailover) error
  • func (r *RedisFailoverHandler) Do(rf *middlev1alpha1.RedisFailover) error
  • func (r *RedisFailoverHandler) Ensure(rf *middlev1alpha1.RedisFailover, labels map[string]string, ...) error
• type StatusWrite
• type StatusWriter
  • func (s *StatusWriter) Patch(ctx context.Context, rf *middlev1alpha1.RedisFailover, patch client.Patch, ...) error
  • func (s *StatusWriter) Update(rf *middlev1alpha1.RedisFailover, opts ...client.UpdateOption) error

Types

type RedisFailoverHandler

type RedisFailoverHandler struct {
	Logger       logr.Logger
	Record       record.EventRecorder
	K8sService   k8s.Services
	RfServices   service.RedisFailoverClient
	RfChecker    service.RedisFailoverCheck
	RfHealer     service.RedisFailoverHeal
	StatusWriter StatusWriter
}

func (*RedisFailoverHandler) CheckAndHeal

func (r *RedisFailoverHandler) CheckAndHeal(rf *middlev1alpha1.RedisFailover) error

func (*RedisFailoverHandler) Do

func (r *RedisFailoverHandler) Do(rf *middlev1alpha1.RedisFailover) error

func (*RedisFailoverHandler) Ensure

func (r *RedisFailoverHandler) Ensure(rf *middlev1alpha1.RedisFailover, labels map[string]string, own []metav1.OwnerReference) error

type StatusWrite

type StatusWrite interface {
	Update(rf *middlev1alpha1.RedisFailover, opts ...client.UpdateOption) error
	Patch(rf *middlev1alpha1.RedisFailover, patch client.Patch, opts ...client.PatchOption) error
}

type StatusWriter

type StatusWriter struct {
	client.Client
	Ctx context.Context
}

func (*StatusWriter) Patch

func (s *StatusWriter) Patch(ctx context.Context, rf *middlev1alpha1.RedisFailover, patch client.Patch, opts ...client.PatchOption) error

func (*StatusWriter) Update

func (s *StatusWriter) Update(rf *middlev1alpha1.RedisFailover, opts ...client.UpdateOption) error