diff --git a/internal/controller/build.go b/internal/controller/build.go index 1522bd3..ffd4599 100644 --- a/internal/controller/build.go +++ b/internal/controller/build.go @@ -1,5 +1,6 @@ package controller +/* import ( "context" v1 "k8s.io/api/core/v1" @@ -229,3 +230,6 @@ func (r *LocustClusterReconciler) BuildLeaderJob(log logr.Logger, locustCluster Status: batch.JobStatus{}, }, nil } + + +*/ diff --git a/internal/controller/locustcluster_controller.go b/internal/controller/locustcluster_controller.go index 60223f4..eb48791 100644 --- a/internal/controller/locustcluster_controller.go +++ b/internal/controller/locustcluster_controller.go @@ -55,7 +55,7 @@ func (r *LocustClusterReconciler) Reconcile(ctx context.Context, req ctrl.Reques // "Namespace", req.Namespace) // locustCluster, err := GetLocustCluster(r.Client, ctx, req.Namespace, req.Name) - locustCluster, err := GetLocustCluster(r.Client, ctx, req.Namespace, req.Name) + _, err := GetLocustCluster(r.Client, ctx, req.Namespace, req.Name) if err != nil { if apierrors.IsNotFound(err) { log.Info("LocustCluster not found") @@ -68,16 +68,17 @@ func (r *LocustClusterReconciler) Reconcile(ctx context.Context, req ctrl.Reques // "Namespace", req.Namespace) return ctrl.Result{Requeue: true}, err } + /* + podList, err := r.IsLeaderUp(log, locustCluster, ctx) + if err != nil { + return ctrl.Result{Requeue: true}, err + } - podList, err := r.IsLeaderUp(log, locustCluster, ctx) - if err != nil { - return ctrl.Result{Requeue: true}, err - } - - err = r.CreateUpdateLeader(log, locustCluster, ctx, podList) - if err != nil { - return ctrl.Result{Requeue: true}, err - } + err = r.CreateUpdateLeader(log, locustCluster, ctx, podList) + if err != nil { + return ctrl.Result{Requeue: true}, err + } + */ return ctrl.Result{}, nil }