Documentation
¶
Overview ¶
Package controller implements the Kubernetes reconciliation logic for Valkey custom resources.
Package controller implements the Kubernetes reconciliation logic for Valkey custom resources.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InstanceChecker ¶ added in v1.0.1
type InstanceChecker interface {
PingPod(ctx context.Context, v *vkov1.Valkey, podName string) error
CheckCluster(ctx context.Context, v *vkov1.Valkey) *health.ClusterState
}
InstanceChecker verifies connectivity and health of Valkey instances. Implementations must provide PingPod for basic connectivity checks and CheckCluster for full HA cluster health verification.
type RollingUpdateResult ¶
type RollingUpdateResult struct {
// NeedsRequeue indicates that the reconciler should requeue after RequeueAfter.
NeedsRequeue bool
// RequeueAfter is the duration to wait before requeuing.
RequeueAfter time.Duration
// Completed indicates the rolling update has fully completed.
Completed bool
// Error holds any error encountered during the rolling update step.
Error error
}
RollingUpdateResult describes the outcome of a rolling update step.
type ValkeyPhase ¶
type ValkeyPhase = vkov1.ValkeyPhase
ValkeyPhase is a type alias to allow constructing rolling update phase strings.
type ValkeyReconciler ¶
type ValkeyReconciler struct {
client.Client
Scheme *runtime.Scheme
InstanceChecker InstanceChecker
OperatorImage string
OperatorNamespace string
}
ValkeyReconciler reconciles a Valkey object.
func (*ValkeyReconciler) Reconcile ¶
Reconcile handles a reconciliation request for a Valkey resource.
func (*ValkeyReconciler) SetupWithManager ¶
func (r *ValkeyReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
Source Files