Documentation ¶
Index ¶
- type RedisReconciler
- func (r *RedisReconciler) AddRedisNodes(instance *redisv1alpha1.Redis) error
- func (r *RedisReconciler) CreateOrUpdateResisService(instance *redisv1alpha1.Redis) error
- func (r *RedisReconciler) CreateOrUpdateResisStatefulSet(instance *redisv1alpha1.Redis) error
- func (r *RedisReconciler) CreateResisCluster(instance *redisv1alpha1.Redis) error
- func (r *RedisReconciler) DeleteRedisNodes(instance *redisv1alpha1.Redis) error
- func (r *RedisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, err error)
- func (r *RedisReconciler) ReconcileRedisStandalone(instance *redisv1alpha1.Redis) error
- func (r *RedisReconciler) SetupWithManager(mgr ctrl.Manager) error
- func (r *RedisReconciler) UpdateRedisNodesStatus(cr *redisv1alpha1.Redis) error
- func (r *RedisReconciler) WaitRedisClusterNodeDelete(instance *redisv1alpha1.Redis, nodeName string) error
- func (r *RedisReconciler) WaitRedisClusterReady(instance *redisv1alpha1.Redis) error
- func (r *RedisReconciler) WaitRedisNodeJoinCluster(instance *redisv1alpha1.Redis, nodeName string) error
- func (r *RedisReconciler) WaitRedisNodeSlotEmpty(instance *redisv1alpha1.Redis, nodeName string) error
- func (r *RedisReconciler) WaitRedisNodesReady(instance *redisv1alpha1.Redis) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisReconciler ¶
type RedisReconciler struct { client.Client K8sClient *res.K8sClient RedisClient *redis.Client Scheme *runtime.Scheme }
RedisReconciler reconciles a Redis object
func (*RedisReconciler) AddRedisNodes ¶
func (r *RedisReconciler) AddRedisNodes(instance *redisv1alpha1.Redis) error
func (*RedisReconciler) CreateOrUpdateResisService ¶
func (r *RedisReconciler) CreateOrUpdateResisService(instance *redisv1alpha1.Redis) error
func (*RedisReconciler) CreateOrUpdateResisStatefulSet ¶
func (r *RedisReconciler) CreateOrUpdateResisStatefulSet(instance *redisv1alpha1.Redis) error
func (*RedisReconciler) CreateResisCluster ¶
func (r *RedisReconciler) CreateResisCluster(instance *redisv1alpha1.Redis) error
func (*RedisReconciler) DeleteRedisNodes ¶
func (r *RedisReconciler) DeleteRedisNodes(instance *redisv1alpha1.Redis) error
func (*RedisReconciler) Reconcile ¶
func (r *RedisReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, err error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Redis object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.7.0/pkg/reconcile
func (*RedisReconciler) ReconcileRedisStandalone ¶
func (r *RedisReconciler) ReconcileRedisStandalone(instance *redisv1alpha1.Redis) error
func (*RedisReconciler) SetupWithManager ¶
func (r *RedisReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
func (*RedisReconciler) UpdateRedisNodesStatus ¶
func (r *RedisReconciler) UpdateRedisNodesStatus(cr *redisv1alpha1.Redis) error
func (*RedisReconciler) WaitRedisClusterNodeDelete ¶
func (r *RedisReconciler) WaitRedisClusterNodeDelete(instance *redisv1alpha1.Redis, nodeName string) error
Waiting for redis cluster node ready
func (*RedisReconciler) WaitRedisClusterReady ¶
func (r *RedisReconciler) WaitRedisClusterReady(instance *redisv1alpha1.Redis) error
Waiting for redis cluster ready
func (*RedisReconciler) WaitRedisNodeJoinCluster ¶
func (r *RedisReconciler) WaitRedisNodeJoinCluster(instance *redisv1alpha1.Redis, nodeName string) error
Waiting for redis cluster node ready
func (*RedisReconciler) WaitRedisNodeSlotEmpty ¶
func (r *RedisReconciler) WaitRedisNodeSlotEmpty(instance *redisv1alpha1.Redis, nodeName string) error
Waiting node slots migrate complete
func (*RedisReconciler) WaitRedisNodesReady ¶
func (r *RedisReconciler) WaitRedisNodesReady(instance *redisv1alpha1.Redis) error
Waiting for redis nodes ready