undo gofumpt

Signed-off-by: Maroon Ayoub <[email protected]>

Author: vMaroon

cmd/epp/main.go

@@ -314,4 +314,5 @@ func verifyMetricMapping(mapping backendmetrics.MetricMapping, logger logr.Logge
 	if mapping.LoraRequestInfo == nil {
 		logger.Info("Not scraping metric: LoraRequestInfo")
 	}
+
 }

pkg/epp/backend/metrics/fake.go

@@ -40,11 +40,9 @@ func (fpm *FakePodMetrics) String() string {
 func (fpm *FakePodMetrics) GetPod() *Pod {
 	return fpm.Pod
 }
-
 func (fpm *FakePodMetrics) GetMetrics() *Metrics {
 	return fpm.Metrics
 }
-
 func (fpm *FakePodMetrics) UpdatePod(pod *corev1.Pod) {
 	fpm.Pod = toInternalPod(pod)
 }

pkg/epp/backend/metrics/metrics.go

@@ -47,6 +47,7 @@ func (p *PodMetricsClientImpl) FetchMetrics(
 	existing *Metrics,
 	port int32,
 ) (*Metrics, error) {
+
 	// Currently the metrics endpoint is hard-coded, which works with vLLM.
 	// TODO(https://github.com/kubernetes-sigs/gateway-api-inference-extension/issues/16): Consume this from InferencePool config.
 	url := "http://" + pod.Address + ":" + strconv.Itoa(int(port)) + "/metrics"

pkg/epp/backend/metrics/metrics_test.go

@@ -58,6 +58,7 @@ func makeMetricFamily(name string, metrics ...*dto.Metric) *dto.MetricFamily {
 // --- Tests ---
 
 func TestGetMetric(t *testing.T) {
+
 	metricFamilies := map[string]*dto.MetricFamily{
 		"metric1": makeMetricFamily("metric1",
 			makeMetric(map[string]string{"label1": "value1"}, 1.0, 1000),
@@ -165,6 +166,7 @@ func TestGetMetric(t *testing.T) {
 
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
+
 			gotMetric, err := p.getMetric(metricFamilies, tt.spec)
 
 			if tt.wantError {
@@ -238,6 +240,7 @@ func TestLabelsMatch(t *testing.T) {
 }
 
 func TestGetLatestLoraMetric(t *testing.T) {
+
 	testCases := []struct {
 		name             string
 		metricFamilies   map[string]*dto.MetricFamily

pkg/epp/backend/metrics/pod_metrics_test.go

@@ -88,12 +88,10 @@ type fakeDataStore struct{}
 func (f *fakeDataStore) PoolGet() (*v1alpha2.InferencePool, error) {
 	return &v1alpha2.InferencePool{Spec: v1alpha2.InferencePoolSpec{TargetPortNumber: 8000}}, nil
 }
-
 func (f *fakeDataStore) PodGetAll() []PodMetrics {
 	// Not implemented.
 	return nil
 }
-
 func (f *fakeDataStore) PodList(func(PodMetrics) bool) []PodMetrics {
 	// Not implemented.
 	return nil

pkg/epp/controller/inferencemodel_reconciler_test.go

@@ -227,6 +227,7 @@ func TestInferenceModelReconciler(t *testing.T) {
 			if diff := diffStore(ds, diffStoreParams{wantPool: pool, wantModels: test.wantModels}); diff != "" {
 				t.Errorf("Unexpected diff (+got/-want): %s", diff)
 			}
+
 		})
 	}
 }

pkg/epp/datastore/datastore.go

@@ -38,7 +38,9 @@ const (
 	ModelNameIndexKey = "spec.modelName"
 )
 
-var errPoolNotSynced = errors.New("InferencePool is not initialized in data store")
+var (
+	errPoolNotSynced = errors.New("InferencePool is not initialized in data store")
+)
 
 // The datastore is a local cache of relevant data for the given InferencePool (currently all pulled from k8s-api)
 type Datastore interface {

pkg/epp/datastore/datastore_test.go

@@ -204,6 +204,7 @@ func TestModel(t *testing.T) {
 				existing := ds.ModelDelete(types.NamespacedName{Name: model1ts.Name, Namespace: model1ts.Namespace})
 				got := ds.ModelGet(tsModel)
 				return existing != nil && got == nil
+
 			},
 			wantOpResult: true,
 			wantModels:   []*v1alpha2.InferenceModel{model2chat},
@@ -225,6 +226,7 @@ func TestModel(t *testing.T) {
 			if diff := testutil.DiffModelLists(test.wantModels, ds.ModelGetAll()); diff != "" {
 				t.Errorf("Unexpected models diff: %s", diff)
 			}
+
 		})
 	}
 }

pkg/epp/scheduling/plugins/filter/filter.go

@@ -214,6 +214,7 @@ var LoRAAffinityFilter = &baseFilter{
 //   - Filtered slice of pod metrics based on affinity and availability
 //   - Error if any issues occur during filtering
 func loRASoftAffinityFilterFunc(ctx *types.SchedulingContext, pods []types.Pod) []types.Pod {
+
 	// Pre-allocate slices with estimated capacity
 	filtered_affinity := make([]types.Pod, 0, len(pods))
 	filtered_available := make([]types.Pod, 0, len(pods))

pkg/epp/scheduling/scheduler_test.go

@@ -536,6 +536,7 @@ func (tp *TestPlugin) Filter(ctx *types.SchedulingContext, pods []types.Pod) []t
 		tp.ReceivedRequestHeaders[key] = value
 	}
 	return findPods(ctx, tp.FilterRes...)
+
 }
 
 func (tp *TestPlugin) Score(ctx *types.SchedulingContext, pods []types.Pod) map[types.Pod]float64 {

test/e2e/epp/e2e_test.go

@@ -87,6 +87,7 @@ var _ = ginkgo.Describe("InferencePool", func() {
 
 				return nil
 			}, readyTimeout, curlInterval).Should(gomega.Succeed())
+
 		})
 	})
 })

test/integration/bbr/hermetic_test.go

@@ -122,8 +122,7 @@ func TestFullDuplexStreamed_BodyBasedRouting(t *testing.T) {
 												RawValue: []byte("foo"),
 											},
 										},
-									},
-								},
+									}},
 							},
 						},
 					},
@@ -188,8 +187,7 @@ func TestFullDuplexStreamed_BodyBasedRouting(t *testing.T) {
 												RawValue: []byte("sql-lora-sheddable"),
 											},
 										},
-									},
-								},
+									}},
 							},
 						},
 					},

test/integration/epp/hermetic_test.go

@@ -121,8 +121,7 @@ func TestFullDuplexStreamed_KubeInferenceModelRequest(t *testing.T) {
 					KVCacheUsagePercent: 0.2,
 				},
 			},
-			wantMetrics: map[string]string{
-				`inference_model_request_total`: `
+			wantMetrics: map[string]string{`inference_model_request_total`: `
 					# HELP inference_model_request_total [ALPHA] Counter of inference model requests broken out for each model and target model.
 					# TYPE inference_model_request_total counter
 					inference_model_request_total{model_name="my-model",target_model_name="my-model-12345"} 1
@@ -154,8 +153,7 @@ func TestFullDuplexStreamed_KubeInferenceModelRequest(t *testing.T) {
 												RawValue: []byte(strconv.Itoa(76)),
 											},
 										},
-									},
-								},
+									}},
 							},
 						},
 					},
@@ -239,8 +237,7 @@ func TestFullDuplexStreamed_KubeInferenceModelRequest(t *testing.T) {
 												RawValue: []byte(strconv.Itoa(76)),
 											},
 										},
-									},
-								},
+									}},
 							},
 						},
 					},

test/utils/utils.go

@@ -240,6 +240,7 @@ func ExecCommandInPod(
 	podNamespace, podName, containerName string,
 	cmd []string,
 ) (string, error) {
+
 	parameterCodec := runtime.NewParameterCodec(scheme)
 
 	req := kubeClient.CoreV1().RESTClient().