Versions in this module Expand all Collapse all v0 v0.0.2 Mar 15, 2023 Changes in this version + 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 uint + const Cluster + const Kubernetes + const NoType + const Redis + const Requeue + const StopRetry + 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 interface + Handler func() error + Name func() string + Tick func() time.Duration + Timeout func() time.Duration + type ReconcileDistributedRedisCluster struct + func (r *ReconcileDistributedRedisCluster) Reconcile(request reconcile.Request) (reconcile.Result, error)