Remove unnesasery methods

Author: goruha

test/component_test.go

@@ -22,10 +22,6 @@ import (
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 
-	"k8s.io/client-go/informers"
-	"sync/atomic"
-	corev1 "k8s.io/api/core/v1"
-
 	"k8s.io/client-go/dynamic"
 	"k8s.io/client-go/dynamic/dynamicinformer"
 	"k8s.io/client-go/tools/cache"
@@ -44,38 +40,6 @@ func (s *ComponentSuite) TestBasic() {
 	clusrerId := atmos.Output(s.T(), clusterOptions, "eks_cluster_id")
 	cluster := awsHelper.GetEksCluster(s.T(), context.Background(), awsRegion, clusrerId)
 
-	clientset, err := awsHelper.NewK8SClientset(cluster)
-	assert.NoError(s.T(), err)
-
-	factoryCluster := informers.NewSharedInformerFactory(clientset, 0)
-	informerCluster := factoryCluster.Core().V1().Nodes().Informer()
-	stopChannelCluster := make(chan struct{})
-	var countOfWorkerNodes uint64 = 0
-
-	informerCluster.AddEventHandler(cache.ResourceEventHandlerFuncs{
-		AddFunc: func(obj interface{}) {
-			node := obj.(*corev1.Node)
-			fmt.Printf("Worker Node %s has joined the EKS cluster at %s\n", node.Name, node.CreationTimestamp)
-			atomic.AddUint64(&countOfWorkerNodes, 1)
-			if countOfWorkerNodes > 1 {
-				close(stopChannelCluster)
-			}
-		},
-	})
-
-	go informerCluster.Run(stopChannelCluster)
-
-	select {
-	case <-stopChannelCluster:
-		msg := "All worker nodes have joined the EKS cluster"
-		fmt.Println(msg)
-	case <-time.After(5 * time.Minute):
-		msg := "Not all worker nodes have joined the EKS cluster"
-		fmt.Println(msg)
-		assert.Fail(s.T(), msg)
-	}
-
-
 	dnsDelegatedOptions := s.GetAtmosOptions("dns-delegated", stack, nil)
 	delegatedDomainName := atmos.Output(s.T(), dnsDelegatedOptions, "default_domain_name")
 	defaultDNSZoneId := atmos.Output(s.T(), dnsDelegatedOptions, "default_dns_zone_id")