Method executeChecks

aws/workloads.go:272–311

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

}

func (m *WorkloadsModule) executeChecks(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Workload) {
	defer wg.Done()
	// Use shared ServiceMap instance if provided, otherwise create a new one
	servicemap := m.ServiceMap
	if servicemap == nil {
		servicemap = &awsservicemap.AwsServiceMap{
			JsonFileSource: "DOWNLOAD_FROM_AWS",
		}
	}

	res, _ := servicemap.IsServiceInRegion("ec2", r)
	if res {
		m.CommandCounter.IncrTotal()
		wg.Add(1)
		go m.getEC2WorkloadsPerRegion(r, wg, semaphore, dataReceiver)
	}

	res, _ = servicemap.IsServiceInRegion("ecs", r)
	if res {
		m.CommandCounter.IncrTotal()
		wg.Add(1)
		go m.getECSWorkloadsPerRegion(r, wg, semaphore, dataReceiver)
	}

	res, err := servicemap.IsServiceInRegion("lambda", r)
	if err != nil {
		m.modLog.Error(err)
	}
	if res {
		m.CommandCounter.IncrTotal()
		wg.Add(1)
		go m.getLambdaWorkloadsPerRegion(r, wg, semaphore, dataReceiver)
	}

	// AppRunner is not supported in the aws service region catalog so we have to run it in all regions
	m.CommandCounter.IncrTotal()
	wg.Add(1)
	go m.getAppRunnerWorkloadsPerRegion(r, wg, semaphore, dataReceiver)

}

func (m *WorkloadsModule) getEC2WorkloadsPerRegion(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Workload) {
	defer func() {