Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ScaleFromZero ¶
func ScaleFromZero(current, sts *appsv1.StatefulSet) bool
ScaleFromZero checks if the current replicas is zero and the desired replicas is greater than zero.
func ScaleToZero ¶
func ScaleToZero(current, sts *appsv1.StatefulSet) bool
ScaleToZero checks if the desired replicas is zero and the current replicas is not zero.
Types ¶
type DeprecatedFeatureReconciler ¶ added in v2.21.1
type DeprecatedFeatureReconciler struct {
client.Client
APIReader client.Reader
RabbitmqClientFactory rabbitmqclient.RabbitmqClientFactory
Interval time.Duration
}
DeprecatedFeatureReconciler reconciles a RabbitmqCluster object to check for deprecated features
func (*DeprecatedFeatureReconciler) Reconcile ¶ added in v2.21.1
func (r *DeprecatedFeatureReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile reads that state of the cluster for a RabbitmqCluster object and makes changes based on the state read and what is in the RabbitmqCluster.Spec
func (*DeprecatedFeatureReconciler) SetupWithManager ¶ added in v2.21.1
func (r *DeprecatedFeatureReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
type PodExecutor ¶
type PodExecutor interface {
Exec(clientset *kubernetes.Clientset, clusterConfig *rest.Config, namespace, podName, containerName string, command ...string) (string, string, error)
}
func NewPodExecutor ¶
func NewPodExecutor() PodExecutor
type RabbitmqClusterReconciler ¶
type RabbitmqClusterReconciler struct {
client.Client
APIReader client.Reader
Scheme *runtime.Scheme
Namespace string
Recorder record.EventRecorder
ClusterConfig *rest.Config
Clientset *kubernetes.Clientset
PodExecutor PodExecutor
RabbitmqClientFactory rabbitmqclient.RabbitmqClientFactory
DefaultRabbitmqImage string
DefaultUserUpdaterImage string
DefaultImagePullSecrets string
ControlRabbitmqImage bool
}
RabbitmqClusterReconciler reconciles a RabbitmqCluster object
func (*RabbitmqClusterReconciler) SetupWithManager ¶
func (r *RabbitmqClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
Source Files
¶
Click to show internal directories.
Click to hide internal directories.