distributedrediscluster

Documentation

Index

• func Add(mgr manager.Manager) error
• func Cause(err error) error
• func FlagSet() *pflag.FlagSet
• func New(msg string) error
• func Newf(msg string, args ...interface{}) error
• func SetClusterFailed(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)
• func SetClusterOK(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)
• func SetClusterRebalancing(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)
• func SetClusterResetPassword(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)
• func SetClusterScaling(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)
• func SetClusterUpdating(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)
• func Wrap(err error, msg string) error
• func Wrapf(err error, msg string, args ...interface{}) error
• type ErrorType
  • func GetType(err error) ErrorType
  • func (errorType ErrorType) New(msg string) error
  • func (errorType ErrorType) Newf(msg string, args ...interface{}) error
  • func (errorType ErrorType) Wrap(err error, msg string) error
  • func (errorType ErrorType) Wrapf(err error, msg string, args ...interface{}) error
• type IWaitHandle
• type ReconcileDistributedRedisCluster
  • func (r *ReconcileDistributedRedisCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new DistributedRedisCluster Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func Cause

func Cause(err error) error

Cause gives the original error

func FlagSet

func FlagSet() *pflag.FlagSet

func New

func New(msg string) error

New creates a no type error

func Newf

func Newf(msg string, args ...interface{}) error

Newf creates a no type error with formatted message

func SetClusterFailed

func SetClusterFailed(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)

func SetClusterOK

func SetClusterOK(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)

func SetClusterRebalancing

func SetClusterRebalancing(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)

func SetClusterResetPassword

func SetClusterResetPassword(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)

func SetClusterScaling

func SetClusterScaling(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)

func SetClusterUpdating

func SetClusterUpdating(status *redisv1alpha1.DistributedRedisClusterStatus, reason string)

func Wrap

func Wrap(err error, msg string) error

Wrap an error with a string

func Wrapf

func Wrapf(err error, msg string, args ...interface{}) error

Wrapf an error with format string

Types

type ErrorType

type ErrorType uint

ErrorType is the type of an error

const (
	// NoType error
	NoType ErrorType = iota
	// Requeue error
	Requeue
	// Kubernetes error
	Kubernetes
	// Redis error
	Redis
	// Cluster
	Cluster
	// StopRetry stop retry error
	StopRetry
)

func GetType

func GetType(err error) ErrorType

GetType returns the error type

func (ErrorType) New

func (errorType ErrorType) New(msg string) error

New creates a new customError

func (ErrorType) Newf

func (errorType ErrorType) Newf(msg string, args ...interface{}) error

New creates a new customError with formatted message

func (ErrorType) Wrap

func (errorType ErrorType) Wrap(err error, msg string) error

Wrap creates a new wrapped error

func (ErrorType) Wrapf

func (errorType ErrorType) Wrapf(err error, msg string, args ...interface{}) error

Wrap creates a new wrapped error with formatted message

type IWaitHandle

type IWaitHandle interface {
	Name() string
	Tick() time.Duration
	Timeout() time.Duration
	Handler() error
}

type ReconcileDistributedRedisCluster

type ReconcileDistributedRedisCluster struct {
	// contains filtered or unexported fields
}

ReconcileDistributedRedisCluster reconciles a DistributedRedisCluster object

func (*ReconcileDistributedRedisCluster) Reconcile

func (r *ReconcileDistributedRedisCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a DistributedRedisCluster object and makes changes based on the state read and what is in the DistributedRedisCluster.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.