Method getEksClustersPerRegion

aws/endpoints.go:483–544

(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint)

}

func (m *EndpointsModule) getEksClustersPerRegion(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint) {
	defer func() {
		m.CommandCounter.DecrExecuting()
		m.CommandCounter.IncrComplete()
		wg.Done()

	}()
	semaphore <- struct{}{}
	defer func() {
		<-semaphore
	}()
	// m.CommandCounter.IncrTotal()
	m.CommandCounter.DecrPending()
	m.CommandCounter.IncrExecuting()
	// "PaginationMarker" is a control variable used for output continuity, as AWS return the output in pages.

	Clusters, err := sdk.CachedEKSListClusters(m.EKSClient, aws.ToString(m.Caller.Account), r)
	if err != nil {
		m.modLog.Error(err.Error())
		m.CommandCounter.IncrError()
		return
	}

	for _, cluster := range Clusters {
		ClusterDetails, err := sdk.CachedEKSDescribeCluster(m.EKSClient, aws.ToString(m.Caller.Account), r, cluster)

		if err != nil {
			if errors.As(err, &oe) {
				m.Errors = append(m.Errors, fmt.Sprintf(" Error: Region: %s, Service: %s, Operation: %s", r, oe.Service(), oe.Operation()))
			}
			m.modLog.Error(err.Error())
			m.CommandCounter.IncrError()
			continue
		}
		var endpoint string
		var name string
		var public string
		vpcConfig := ClusterDetails.ResourcesVpcConfig.EndpointPublicAccess
		if vpcConfig {
			//
			if ClusterDetails.ResourcesVpcConfig.PublicAccessCidrs[0] == "0.0.0.0/0" {
				public = "True"
			} else {
				public = "False"
			}
		}

		endpoint = aws.ToString(ClusterDetails.Endpoint)
		name = aws.ToString(ClusterDetails.Name)
		dataReceiver <- Endpoint{
			AWSService: "Eks",
			Region:     r,
			Name:       name,
			Endpoint:   endpoint,
			Port:       443,
			Protocol:   "https",
			Public:     public,
		}