(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan EnvironmentVariable)
| 280 | } |
| 281 | |
| 282 | func (m *EnvsModule) executeChecks(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan EnvironmentVariable) { |
| 283 | defer wg.Done() |
| 284 | // Use shared ServiceMap instance if provided, otherwise create a new one |
| 285 | servicemap := m.ServiceMap |
| 286 | if servicemap == nil { |
| 287 | servicemap = &awsservicemap.AwsServiceMap{ |
| 288 | JsonFileSource: "DOWNLOAD_FROM_AWS", |
| 289 | } |
| 290 | } |
| 291 | res, _ := servicemap.IsServiceInRegion("ecs", r) |
| 292 | if res { |
| 293 | m.CommandCounter.IncrTotal() |
| 294 | wg.Add(1) |
| 295 | go m.getECSEnvironmentVariablesPerRegion(r, wg, semaphore, dataReceiver) |
| 296 | } |
| 297 | |
| 298 | res, err := servicemap.IsServiceInRegion("lambda", r) |
| 299 | if err != nil { |
| 300 | m.modLog.Error(err) |
| 301 | } |
| 302 | if res { |
| 303 | m.CommandCounter.IncrTotal() |
| 304 | wg.Add(1) |
| 305 | go m.getLambdaEnvironmentVariablesPerRegion(r, wg, semaphore, dataReceiver) |
| 306 | } |
| 307 | |
| 308 | // AppRunner is not supported in the aws service region catalog so we have to run it in all regions |
| 309 | m.CommandCounter.IncrTotal() |
| 310 | wg.Add(1) |
| 311 | go m.getAppRunnerEnvironmentVariablesPerRegion(r, wg, semaphore, dataReceiver) |
| 312 | |
| 313 | res, err = servicemap.IsServiceInRegion("amazonlightsail.com", r) |
| 314 | if err != nil { |
| 315 | m.modLog.Error(err) |
| 316 | } |
| 317 | if res { |
| 318 | m.CommandCounter.IncrTotal() |
| 319 | wg.Add(1) |
| 320 | go m.getLightsailEnvironmentVariablesPerRegion(r, wg, semaphore, dataReceiver) |
| 321 | } |
| 322 | |
| 323 | res, err = servicemap.IsServiceInRegion("sagemaker-ai", r) |
| 324 | if err != nil { |
| 325 | m.modLog.Error(err) |
| 326 | } |
| 327 | if res { |
| 328 | m.CommandCounter.IncrTotal() |
| 329 | wg.Add(1) |
| 330 | go m.getSagemakerEnvironmentVariablesPerRegion(r, wg, semaphore, dataReceiver) |
| 331 | } |
| 332 | |
| 333 | } |
| 334 | |
| 335 | func (m *EnvsModule) getECSEnvironmentVariablesPerRegion(region string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan EnvironmentVariable) { |
| 336 | defer func() { |
no test coverage detected