Add the informer for getting a Pod by the node name (#1903)

Author: johscheuer

controllers/cluster_controller.go

@@ -252,6 +252,7 @@ func (r *FoundationDBClusterReconciler) SetupWithManager(mgr ctrl.Manager, maxCo
 	if err != nil {
 		return err
 	}
+
 	labelSelectorPredicate, err := predicate.LabelSelectorPredicate(selector)
 	if err != nil {
 		return err

kubectl-fdb/cmd/cordon.go

@@ -182,6 +182,7 @@ func cordonNode(cmd *cobra.Command, kubeClient client.Client, inputClusterName s
 	if len(errors) > 0 {
 		return fmt.Errorf("following operation failed, please check and retry: \n, %s", errors)
 	}
+
 	return nil
 }
 
@@ -211,6 +212,7 @@ func fetchPods(kubeClient client.Client, clusterName string, namespace string, n
 	if err != nil {
 		return pods, fmt.Errorf("unable to fetch pods. Error: %w", err)
 	}
+
 	return pods, nil
 }
 

kubectl-fdb/cmd/k8s_client.go

@@ -86,6 +86,16 @@ func getKubeClient(ctx context.Context, o *fdbBOptions) (client.Client, error) {
 		return nil, err
 	}
 
+	// Setup index field to allow access to the node name more efficiently. The indexer must be created before the
+	// informer is started.
+	err = internalCache.IndexField(ctx, &corev1.Pod{}, "spec.nodeName", func(object client.Object) []string {
+		return []string{object.(*corev1.Pod).Spec.NodeName}
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
 	// Make sure the internal cache is started.
 	go func() {
 		_ = internalCache.Start(ctx)