controller

package
v0.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 17, 2026 License: Apache-2.0 Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ValkeyACLReconciler

type ValkeyACLReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ValkeyACLReconciler reconciles a ValkeyACL object.

func (*ValkeyACLReconciler) Reconcile

func (r *ValkeyACLReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, retErr error)

func (*ValkeyACLReconciler) SetupWithManager

func (r *ValkeyACLReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager registers the controller.

type ValkeyClusterReconciler

type ValkeyClusterReconciler struct {
	client.Client
	// APIReader is an uncached, read-through client. The embedded Client serves
	// reads from the informer cache, which lags writes; for the once-per-token
	// password-rotation guard we need an authoritative status read so a second,
	// quickly-following reconcile doesn't re-run a rotation the first already did.
	APIReader client.Reader
	Scheme    *runtime.Scheme
	// MaxConcurrentReconciles caps how many ValkeyClusters reconcile in parallel.
	// controller-runtime never runs two reconciles for the SAME object at once,
	// so raising this only parallelises across DIFFERENT clusters — the default
	// of 1 serialises the whole fleet and bottlenecks at 500+ CRs (design-review
	// Q3/SC2). 0 falls back to 1.
	MaxConcurrentReconciles int
}

ValkeyClusterReconciler reconciles a ValkeyCluster object.

func (*ValkeyClusterReconciler) Reconcile

func (r *ValkeyClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, retErr error)

func (*ValkeyClusterReconciler) SetupWithManager

func (r *ValkeyClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager wires the controller and owned objects.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL