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
	Scheme        *runtime.Scheme
	Namespace     string
	Recorder      record.EventRecorder
	ClusterConfig *rest.Config
	Clientset     *kubernetes.Clientset
	PodExecutor   PodExecutor
}

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