fix v2 lint issues

Signed-off-by: Etai Lev Ran <elevran@gmail.com>

Author: elevran

conformance/conformance.go

@@ -296,7 +296,7 @@ func ensureGatewayAvailableAndReady(t *testing.T, k8sClient client.Client, opts
 	extTimeoutConf := inferenceconfig.DefaultInferenceExtensionTimeoutConfig()
 
 	// Use the GatewayMustHaveAddress timeout from the suite's base TimeoutConfig for the Gateway object to appear.
-	waitForGatewayCreationTimeout := extTimeoutConf.TimeoutConfig.GatewayMustHaveAddress
+	waitForGatewayCreationTimeout := extTimeoutConf.GatewayMustHaveAddress
 
 	logDebugf(t, opts.Debug, "Waiting up to %v for Gateway object %s/%s to appear after manifest application...", waitForGatewayCreationTimeout, gatewayNN.Namespace, gatewayNN.Name)
 

conformance/tests/basic/gateway_following_epp_routing.go

@@ -33,7 +33,6 @@ import (
 	"sigs.k8s.io/gateway-api-inference-extension/conformance/tests"
 	k8sutils "sigs.k8s.io/gateway-api-inference-extension/conformance/utils/kubernetes"
 	"sigs.k8s.io/gateway-api-inference-extension/conformance/utils/traffic"
-	trafficutils "sigs.k8s.io/gateway-api-inference-extension/conformance/utils/traffic"
 )
 
 func init() {
@@ -94,12 +93,12 @@ var GatewayFollowingEPPRouting = suite.ConformanceTest{
 		for i := 0; i < len(pods); i++ {
 			// Send an initial request targeting a single pod and wait for it to be successful to ensure the Gateway and EPP
 			// are functioning correctly before running the main test cases.
-			trafficutils.MakeRequestAndExpectSuccess(
+			traffic.MakeRequestAndExpectSuccess(
 				t,
 				s.RoundTripper,
 				s.TimeoutConfig,
 				gwAddr,
-				trafficutils.Request{
+				traffic.Request{
 					Host:      hostname,
 					Path:      path,
 					Headers:   map[string]string{eppSelectionHeaderName: podIPs[i]},

conformance/utils/kubernetes/helpers.go

@@ -72,7 +72,7 @@ func checkCondition(t *testing.T, conditions []metav1.Condition, expectedConditi
 func InferencePoolMustHaveCondition(t *testing.T, c client.Reader, poolNN types.NamespacedName, expectedCondition metav1.Condition) {
 	t.Helper() // Marks this function as a test helper
 
-	var timeoutConfig config.InferenceExtensionTimeoutConfig = config.DefaultInferenceExtensionTimeoutConfig()
+	var timeoutConfig = config.DefaultInferenceExtensionTimeoutConfig()
 	var lastObservedPool *inferenceapi.InferencePool
 	var lastError error
 	var conditionFound bool
@@ -165,7 +165,7 @@ func InferencePoolMustHaveNoParents(t *testing.T, c client.Reader, poolNN types.
 
 	var lastObservedPool *inferenceapi.InferencePool
 	var lastError error
-	var timeoutConfig config.InferenceExtensionTimeoutConfig = config.DefaultInferenceExtensionTimeoutConfig()
+	var timeoutConfig = config.DefaultInferenceExtensionTimeoutConfig()
 
 	ctx := context.Background()
 	waitErr := wait.PollUntilContextTimeout(
@@ -286,7 +286,7 @@ func HTTPRouteAndInferencePoolMustBeAcceptedAndRouteAccepted(
 	gatewayNN types.NamespacedName,
 	poolNN types.NamespacedName) {
 	t.Helper()
-	var timeoutConfig config.InferenceExtensionTimeoutConfig = config.DefaultInferenceExtensionTimeoutConfig()
+	var timeoutConfig = config.DefaultInferenceExtensionTimeoutConfig()
 
 	HTTPRouteMustBeAcceptedAndResolved(t, c, timeoutConfig.TimeoutConfig, routeNN, gatewayNN)
 	InferencePoolMustBeRouteAccepted(t, c, poolNN)

pkg/bbr/handlers/request.go

@@ -23,7 +23,6 @@ import (
 
 	basepb "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
 	eppb "github.com/envoyproxy/go-control-plane/envoy/service/ext_proc/v3"
-	extProcPb "github.com/envoyproxy/go-control-plane/envoy/service/ext_proc/v3"
 	"sigs.k8s.io/controller-runtime/pkg/log"
 
 	"sigs.k8s.io/gateway-api-inference-extension/pkg/bbr/metrics"
@@ -122,13 +121,13 @@ func (s *Server) HandleRequestBody(ctx context.Context, requestBodyBytes []byte)
 }
 
 func addStreamedBodyResponse(responses []*eppb.ProcessingResponse, requestBodyBytes []byte) []*eppb.ProcessingResponse {
-	return append(responses, &extProcPb.ProcessingResponse{
-		Response: &extProcPb.ProcessingResponse_RequestBody{
-			RequestBody: &extProcPb.BodyResponse{
-				Response: &extProcPb.CommonResponse{
-					BodyMutation: &extProcPb.BodyMutation{
-						Mutation: &extProcPb.BodyMutation_StreamedResponse{
-							StreamedResponse: &extProcPb.StreamedBodyResponse{
+	return append(responses, &eppb.ProcessingResponse{
+		Response: &eppb.ProcessingResponse_RequestBody{
+			RequestBody: &eppb.BodyResponse{
+				Response: &eppb.CommonResponse{
+					BodyMutation: &eppb.BodyMutation{
+						Mutation: &eppb.BodyMutation_StreamedResponse{
+							StreamedResponse: &eppb.StreamedBodyResponse{
 								Body:        requestBodyBytes,
 								EndOfStream: true,
 							},

pkg/epp/datastore/datastore.go

@@ -175,7 +175,7 @@ func (ds *datastore) ModelSetIfOlder(infModel *v1alpha2.InferenceModel) bool {
 	existing, exists := ds.models[infModel.Spec.ModelName]
 	if exists {
 		diffObj := infModel.Name != existing.Name || infModel.Namespace != existing.Namespace
-		if diffObj && existing.ObjectMeta.CreationTimestamp.Before(&infModel.ObjectMeta.CreationTimestamp) {
+		if diffObj && existing.CreationTimestamp.Before(&infModel.CreationTimestamp) {
 			return false
 		}
 	}
@@ -205,7 +205,7 @@ func (ds *datastore) ModelResync(ctx context.Context, reader client.Reader, mode
 			!m.DeletionTimestamp.IsZero() { // ignore objects marked for deletion
 			continue
 		}
-		if oldest == nil || m.ObjectMeta.CreationTimestamp.Before(&oldest.ObjectMeta.CreationTimestamp) {
+		if oldest == nil || m.CreationTimestamp.Before(&oldest.CreationTimestamp) {
 			oldest = m
 		}
 	}

pkg/epp/util/testing/wrappers.go

@@ -101,7 +101,7 @@ func (p *PodWrapper) IP(ip string) *PodWrapper {
 func (p *PodWrapper) DeletionTimestamp() *PodWrapper {
 	now := metav1.Now()
 	p.ObjectMeta.DeletionTimestamp = &now
-	p.ObjectMeta.Finalizers = []string{"finalizer"}
+	p.Finalizers = []string{"finalizer"}
 	return p
 }
 
@@ -160,7 +160,7 @@ func (m *InferenceModelWrapper) Criticality(criticality v1alpha2.Criticality) *I
 func (m *InferenceModelWrapper) DeletionTimestamp() *InferenceModelWrapper {
 	now := metav1.Now()
 	m.ObjectMeta.DeletionTimestamp = &now
-	m.ObjectMeta.Finalizers = []string{"finalizer"}
+	m.Finalizers = []string{"finalizer"}
 	return m
 }
 

pkg/generator/main.go

@@ -79,10 +79,10 @@ func main() {
 		crdRaw := parser.CustomResourceDefinitions[groupKind]
 
 		// Inline version of "addAttribution(&crdRaw)" ...
-		if crdRaw.ObjectMeta.Annotations == nil {
-			crdRaw.ObjectMeta.Annotations = map[string]string{}
+		if crdRaw.Annotations == nil {
+			crdRaw.Annotations = map[string]string{}
 		}
-		crdRaw.ObjectMeta.Annotations[version.BundleVersionAnnotation] = version.BundleVersion
+		crdRaw.Annotations[version.BundleVersionAnnotation] = version.BundleVersion
 
 		// Prevent the top level metadata for the CRD to be generated regardless of the intention in the arguments
 		crd.FixTopLevelMetadata(crdRaw)