Documentation
¶
Index ¶
- func SetAlertManagerWithManager(mgr manager.Manager) error
- func SetupKafkaClusterWithManager(mgr ctrl.Manager, log logr.Logger) *ctrl.Builder
- func SetupKafkaTopicWithManager(mgr ctrl.Manager) error
- func SetupKafkaUserWithManager(mgr ctrl.Manager) error
- type AController
- type KafkaClusterReconciler
- type KafkaTopicReconciler
- type KafkaUserReconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetAlertManagerWithManager ¶
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 SetupKafkaClusterWithManager ¶
SetupKafkaClusterWithManager registers kafka cluster controller to the manager
func SetupKafkaTopicWithManager ¶
SetupKafkaTopicWithManager registers kafka topic controller with manager
func SetupKafkaUserWithManager ¶
SetupKafkaUserWithManager registers KafkaUser controller to the manager
Types ¶
type AController ¶
AController implements Runnable
func (AController) Start ¶
func (c AController) Start(<-chan struct{}) error
Start initiates the alertmanager controller
type KafkaClusterReconciler ¶
KafkaClusterReconciler reconciles a KafkaCluster object
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
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 ¶
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 Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.
Source Files