controllers

Jun 8, 2026

Changes in this version

+ type DeprecatedFeatureReconciler struct

+ APIReader client.Reader

+ Interval time.Duration

+ RabbitmqClientFactory rabbitmqclient.RabbitmqClientFactory

+ func (r *DeprecatedFeatureReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *DeprecatedFeatureReconciler) SetupWithManager(mgr ctrl.Manager) error

May 13, 2026

Changes in this version

type RabbitmqClusterReconciler

+ RabbitmqClientFactory rabbitmqclient.RabbitmqClientFactory

Mar 25, 2026

Changes in this version

+ func ScaleFromZero(current, sts *appsv1.StatefulSet) bool

+ func ScaleToZero(current, sts *appsv1.StatefulSet) bool

+ type PodExecutor interface

+ Exec func(clientset *kubernetes.Clientset, clusterConfig *rest.Config, ...) (string, string, error)

+ func NewPodExecutor() PodExecutor

+ type RabbitmqClusterReconciler struct

+ APIReader client.Reader

+ Clientset *kubernetes.Clientset

+ ClusterConfig *rest.Config

+ ControlRabbitmqImage bool

+ DefaultImagePullSecrets string

+ DefaultRabbitmqImage string

+ DefaultUserUpdaterImage string

+ Namespace string

+ PodExecutor PodExecutor

+ Recorder record.EventRecorder

+ Scheme *runtime.Scheme

+ func (r *RabbitmqClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *RabbitmqClusterReconciler) SetupWithManager(mgr ctrl.Manager) error