Method executeChecks

aws/inventory.go:424–796

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

}

func (m *Inventory2Module) executeChecks(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan GlobalResourceCount2) {
	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",
		}
	}

	// 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.getAppRunnerServicesPerRegion(r, wg, semaphore)

	res, err := servicemap.IsServiceInRegion("api-gateway", r)
	if err != nil {
		m.modLog.Error(err)
	}
	if res {
		m.CommandCounter.IncrTotal()
		wg.Add(1)
		go m.getAPIGatewayvAPIsPerRegion(r, wg, semaphore)

		m.CommandCounter.IncrTotal()
		wg.Add(1)
		go m.getAPIGatewayv2APIsPerRegion(r, wg, semaphore)
	}

	res, err = servicemap.IsServiceInRegion("athena", r)
	if err != nil {
		m.modLog.Error(err)
	}
	if res {
		m.CommandCounter.IncrTotal()
		wg.Add(1)
		go m.getAthenaDatabasesPerRegion(r, wg, semaphore)
		// wg.Add(1)
		// go m.getAthenaDataCatalogsPerRegion(r, wg, semaphore)
	}

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

	res, err = servicemap.IsServiceInRegion("cloudformation", r)
	if err != nil {
		m.modLog.Error(err)
	}
	if res {
		m.CommandCounter.IncrTotal()