controllers

Documentation

Index

• type SuperStreamConsumerReconciler
  • func (r *SuperStreamConsumerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SuperStreamConsumerReconciler) SetReconcileSuccess(ctx context.Context, superStreamConsumer *sacv1alpha1.SuperStreamConsumer, ...) error
  • func (r *SuperStreamConsumerReconciler) SetupWithManager(mgr ctrl.Manager) error

Types

type SuperStreamConsumerReconciler

type SuperStreamConsumerReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

SuperStreamConsumerReconciler reconciles a SuperStreamConsumer object

func (*SuperStreamConsumerReconciler) Reconcile

func (r *SuperStreamConsumerReconciler) 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.

func (*SuperStreamConsumerReconciler) SetReconcileSuccess

func (r *SuperStreamConsumerReconciler) SetReconcileSuccess(ctx context.Context, superStreamConsumer *sacv1alpha1.SuperStreamConsumer, condition topology.Condition) error

func (*SuperStreamConsumerReconciler) SetupWithManager

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