controllers

Jul 30, 2025

Changes in this version

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

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

Apr 3, 2024

Changes in this version

type RabbitmqClusterReconciler

+ APIReader client.Reader

Aug 24, 2023

Changes in this version

+ type PodExecutor interface

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

+ func NewPodExecutor() PodExecutor

+ type RabbitmqClusterReconciler struct

+ 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