controllers

Documentation

Overview

Package controllers implements controllers.

Index

• func ConnectionRefMapper(object client.Object) []reconcile.Request
• type PulsarConnectionReconciler
  • func (r *PulsarConnectionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PulsarConnectionReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
• type PulsarConnectionRefMapper
  • func (p *PulsarConnectionRefMapper) Map(object client.Object) []reconcile.Request

Functions

func ConnectionRefMapper

func ConnectionRefMapper(object client.Object) []reconcile.Request

ConnectionRefMapper maps resource object to PulsarConnection request

Types

type PulsarConnectionReconciler

type PulsarConnectionReconciler struct {
	client.Client
	Scheme             *runtime.Scheme
	Log                logr.Logger
	Recorder           record.EventRecorder
	PulsarAdminCreator admin.PulsarAdminCreator
	Retryer            *utils.ReconcileRetryer
}

PulsarConnectionReconciler reconciles a PulsarConnection object

func (*PulsarConnectionReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the PulsarConnection object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile

func (*PulsarConnectionReconciler) SetupWithManager

func (r *PulsarConnectionReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

SetupWithManager sets up the controller with the Manager.

type PulsarConnectionRefMapper

type PulsarConnectionRefMapper struct {
}

PulsarConnectionRefMapper maps resource requests to PulsarConnection

func (*PulsarConnectionRefMapper) Map

func (p *PulsarConnectionRefMapper) Map(object client.Object) []reconcile.Request

Map maps resource object to PulsarConnection request