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 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
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.