controllers

Documentation

Index

• func SetAlertManagerWithManager(mgr manager.Manager) error
• func SetNewKafkaFromCluster(...)
• func SetupCruiseControlWithManager(mgr ctrl.Manager) *ctrl.Builder
• func SetupKafkaClusterWithManager(mgr ctrl.Manager, log logr.Logger) *ctrl.Builder
• func SetupKafkaTopicWithManager(mgr ctrl.Manager, maxConcurrentReconciles int) error
• func SetupKafkaUserWithManager(mgr ctrl.Manager, certSigningEnabled bool, certManagerNamespace bool, ...) *ctrl.Builder
• type AController
  • func (c AController) Start(ctx context.Context) error
• type CruiseControlTaskReconciler
  • func (r *CruiseControlTaskReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
• type KafkaClusterReconciler
  • func (r *KafkaClusterReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
• type KafkaTopicReconciler
  • func (r *KafkaTopicReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type KafkaUserReconciler
  • func (r *KafkaUserReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Functions

func SetAlertManagerWithManager

func SetAlertManagerWithManager(mgr manager.Manager) error

SetAlertManagerWithManager creates a new Alertmanager Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

func SetNewKafkaFromCluster

func SetNewKafkaFromCluster(f func(k8sclient client.Client, cluster *v1beta1.KafkaCluster) (kafkaclient.KafkaClient, func(), error))

func SetupCruiseControlWithManager

func SetupCruiseControlWithManager(mgr ctrl.Manager) *ctrl.Builder

SetupCruiseControlWithManager registers cruise control controller to the manager

func SetupKafkaClusterWithManager

func SetupKafkaClusterWithManager(mgr ctrl.Manager, log logr.Logger) *ctrl.Builder

SetupKafkaClusterWithManager registers kafka cluster controller to the manager

func SetupKafkaTopicWithManager

func SetupKafkaTopicWithManager(mgr ctrl.Manager, maxConcurrentReconciles int) error

SetupKafkaTopicWithManager registers kafka topic controller with manager

func SetupKafkaUserWithManager

func SetupKafkaUserWithManager(mgr ctrl.Manager, certSigningEnabled bool, certManagerNamespace bool, log logr.Logger) *ctrl.Builder

SetupKafkaUserWithManager registers KafkaUser controller to the manager

Types

type AController

type AController struct {
	Client client.Client
}

AController implements Runnable

func (AController) Start

func (c AController) Start(ctx context.Context) error

Start initiates the alertmanager controller

type CruiseControlTaskReconciler

type CruiseControlTaskReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	Log logr.Logger
}

CruiseControlTaskReconciler reconciles a kafka cluster object

func (*CruiseControlTaskReconciler) Reconcile

func (r *CruiseControlTaskReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

type KafkaClusterReconciler

type KafkaClusterReconciler struct {
	client.Client
	DirectClient        client.Reader
	Log                 logr.Logger
	Namespaces          []string
	KafkaClientProvider kafkaclient.Provider
}

KafkaClusterReconciler reconciles a KafkaCluster object

func (*KafkaClusterReconciler) Reconcile

func (r *KafkaClusterReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

type KafkaTopicReconciler

type KafkaTopicReconciler struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	Client client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger
}

KafkaTopicReconciler reconciles a KafkaTopic object

func (*KafkaTopicReconciler) Reconcile

func (r *KafkaTopicReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reconciles the kafka topic

type KafkaUserReconciler

type KafkaUserReconciler struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	Client client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger
}

KafkaUserReconciler reconciles a KafkaUser object

func (*KafkaUserReconciler) Reconcile

func (r *KafkaUserReconciler) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a KafkaUser object and makes changes based on the state read and what is in the KafkaUser.Spec