crichardson/locust-operator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

comment out
Some checks failed
Build images / Run e2e tests (push) Failing after 40s
Details
E2E Tests / Run on Ubuntu (push) Failing after 49s
Details
Build images / Run lint test (push) Failing after 6m4s
Details
Lint / Run on Ubuntu (push) Failing after 6m47s
Details
Build images / Run unit test (push) Failing after 8m42s
Details
Build images / Build docker image (push) Has been skipped
Details
Tests / Run on Ubuntu (push) Failing after 7m45s
Details

Browse Source
This commit is contained in:
Chris Richardson
2025-07-02 13:11:48 -04:00
parent 4d9663fe60
commit 9aecad4697
2 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/controller/build.go
View File

@@ -1,5 +1,6 @@
package controller package controller
/*
import ( import (
"context" "context"
v1 "k8s.io/api/core/v1" v1 "k8s.io/api/core/v1"
@@ -229,3 +230,6 @@ func (r *LocustClusterReconciler) BuildLeaderJob(log logr.Logger, locustCluster
Status: batch.JobStatus{}, Status: batch.JobStatus{},
}, nil }, nil
} }
*/

21
internal/controller/locustcluster_controller.go
View File

@@ -55,7 +55,7 @@ func (r *LocustClusterReconciler) Reconcile(ctx context.Context, req ctrl.Reques
// "Namespace", req.Namespace) // "Namespace", req.Namespace)
// locustCluster, err := GetLocustCluster(r.Client, ctx, req.Namespace, req.Name) // 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 err != nil {
if apierrors.IsNotFound(err) { if apierrors.IsNotFound(err) {
log.Info("LocustCluster not found") log.Info("LocustCluster not found")
@@ -68,16 +68,17 @@ func (r *LocustClusterReconciler) Reconcile(ctx context.Context, req ctrl.Reques
// "Namespace", req.Namespace) // "Namespace", req.Namespace)
return ctrl.Result{Requeue: true}, err 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) err = r.CreateUpdateLeader(log, locustCluster, ctx, podList)
if err != nil { if err != nil {
return ctrl.Result{Requeue: true}, err 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 return ctrl.Result{}, nil
} }