[chore] added back changes to update delete

Signed-off-by: RealAnna <[email protected]>

Author: RealAnna

processor/k8sattributesprocessor/internal/kube/informer_test.go

@@ -11,9 +11,11 @@ import (
 	"github.com/stretchr/testify/require"
 	api_v1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/apimachinery/pkg/selection"
 	clientmeta "k8s.io/client-go/metadata"
+	clientmetafake "k8s.io/client-go/metadata/fake"
 	"k8s.io/client-go/tools/cache"
 
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/k8sconfig"
@@ -171,7 +173,7 @@ func Test_fakeNamespaceInformer(t *testing.T) {
 }
 
 func Test_replicasetListFuncWithSelectors(t *testing.T) {
-	mc := newTestMetadataClient(t)
+	mc := newTestMetadataClient()
 	gvr := schema.GroupVersionResource{Group: "apps", Version: "v1", Resource: "replicasets"}
 	listFunc := replicaSetListFuncWithSelectors(mc, gvr, "test-ns")
 	opts := metav1.ListOptions{}
@@ -181,7 +183,7 @@ func Test_replicasetListFuncWithSelectors(t *testing.T) {
 }
 
 func Test_replicasetWatchFuncWithSelectors(t *testing.T) {
-	mc := newTestMetadataClient(t)
+	mc := newTestMetadataClient()
 	gvr := schema.GroupVersionResource{Group: "apps", Version: "v1", Resource: "replicasets"}
 	watchFunc := replicaSetWatchFuncWithSelectors(mc, gvr, "test-ns")
 	opts := metav1.ListOptions{}
@@ -191,29 +193,16 @@ func Test_replicasetWatchFuncWithSelectors(t *testing.T) {
 }
 
 func Test_newReplicaSetsharedInformer(t *testing.T) {
-	mc := newTestMetadataClient(t)
+	mc := newTestMetadataClient()
 	informer := newReplicaSetSharedInformer(mc, "test-ns")
 	if informer == nil {
 		t.Fatalf("Expected informer to be non-nil, but got nil. Check logs for details.")
 	}
 	assert.NotNil(t, informer)
 }
 
-func newTestMetadataClient(t *testing.T) clientmeta.Interface {
-	t.Setenv("KUBERNETES_SERVICE_HOST", "127.0.0.1")
-	t.Setenv("KUBERNETES_SERVICE_PORT", "6443")
-
-	apiCfg := k8sconfig.APIConfig{
-		AuthType: "none",
-	}
-
-	// Create rest.Config from apiCfg
-	restCfg, err := k8sconfig.CreateRestConfig(apiCfg)
-	require.NoError(t, err)
-
-	// Create metadata client from rest.Config
-	mc, err := clientmeta.NewForConfig(restCfg)
-	require.NoError(t, err)
+func newTestMetadataClient() clientmeta.Interface {
+	mc := clientmetafake.NewSimpleMetadataClient(runtime.NewScheme()) // or NewSimpleClientset for older versions
 	return mc
 }