controllers

Documentation

Index

• type PodExecutor
  • func NewPodExecutor() PodExecutor
• type RabbitmqClusterReconciler
  • func (r *RabbitmqClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *RabbitmqClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

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) Reconcile

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

func (*RabbitmqClusterReconciler) SetupWithManager

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