controller

Documentation

Index

• type PulsarClusterReconciler
  • func (r *PulsarClusterReconciler) Configure(ctx reconciler.Context) error
  • func (r *PulsarClusterReconciler) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)
• type PulsarManagerReconciler
  • func (r *PulsarManagerReconciler) Configure(ctx reconciler.Context) error
  • func (r *PulsarManagerReconciler) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)
• type PulsarProxyReconciler
  • func (r *PulsarProxyReconciler) Configure(ctx reconciler.Context) error
  • func (r *PulsarProxyReconciler) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Types

type PulsarClusterReconciler

type PulsarClusterReconciler struct {
	reconciler.Context
}

PulsarClusterReconciler reconciles a PulsarCluster object

func (*PulsarClusterReconciler) Configure

func (r *PulsarClusterReconciler) Configure(ctx reconciler.Context) error

Configure configures the above PulsarClusterReconciler

func (*PulsarClusterReconciler) Reconcile

func (r *PulsarClusterReconciler) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile handles reconciliation request for PulsarCluster instances

type PulsarManagerReconciler

type PulsarManagerReconciler struct {
	reconciler.Context
}

PulsarManagerReconciler reconciles a PulsarManager object

func (*PulsarManagerReconciler) Configure

func (r *PulsarManagerReconciler) Configure(ctx reconciler.Context) error

Configure configures the above PulsarManagerReconciler

func (*PulsarManagerReconciler) Reconcile

func (r *PulsarManagerReconciler) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile handles reconciliation request for PulsarManager instances

type PulsarProxyReconciler

type PulsarProxyReconciler struct {
	reconciler.Context
}

PulsarProxyReconciler reconciles a PulsarProxy object

func (*PulsarProxyReconciler) Configure

func (r *PulsarProxyReconciler) Configure(ctx reconciler.Context) error

Configure configures the above PulsarProxyReconciler

func (*PulsarProxyReconciler) Reconcile

func (r *PulsarProxyReconciler) Reconcile(_ context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile handles reconciliation request for PulsarProxy instances