(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint)
| 261 | } |
| 262 | |
| 263 | func (m *EndpointsModule) executeChecks(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Endpoint) { |
| 264 | defer wg.Done() |
| 265 | // check the concurrency semaphore |
| 266 | // semaphore <- struct{}{} |
| 267 | // defer func() { |
| 268 | // <-semaphore |
| 269 | // }() |
| 270 | |
| 271 | // Use shared ServiceMap instance if provided, otherwise create a new one |
| 272 | servicemap := m.ServiceMap |
| 273 | if servicemap == nil { |
| 274 | servicemap = &awsservicemap.AwsServiceMap{ |
| 275 | JsonFileSource: "DOWNLOAD_FROM_AWS", |
| 276 | } |
| 277 | } |
| 278 | res, err := servicemap.IsServiceInRegion("lambda", r) |
| 279 | if err != nil { |
| 280 | m.modLog.Error(err) |
| 281 | } |
| 282 | if res { |
| 283 | m.CommandCounter.IncrTotal() |
| 284 | wg.Add(1) |
| 285 | go m.getLambdaFunctionsPerRegion(r, wg, semaphore, dataReceiver) |
| 286 | } |
| 287 | res, err = servicemap.IsServiceInRegion("eks", r) |
| 288 | if err != nil { |
| 289 | m.modLog.Error(err) |
| 290 | } |
| 291 | if res { |
| 292 | m.CommandCounter.IncrTotal() |
| 293 | wg.Add(1) |
| 294 | go m.getEksClustersPerRegion(r, wg, semaphore, dataReceiver) |
| 295 | } |
| 296 | res, err = servicemap.IsServiceInRegion("amazon-mq", r) |
| 297 | if err != nil { |
| 298 | m.modLog.Error(err) |
| 299 | } |
| 300 | if res { |
| 301 | m.CommandCounter.IncrTotal() |
| 302 | wg.Add(1) |
| 303 | go m.getMqBrokersPerRegion(r, wg, semaphore, dataReceiver) |
| 304 | } |
| 305 | res, err = servicemap.IsServiceInRegion("opensearch-service", r) |
| 306 | if err != nil { |
| 307 | m.modLog.Error(err) |
| 308 | } |
| 309 | if res { |
| 310 | m.CommandCounter.IncrTotal() |
| 311 | wg.Add(1) |
| 312 | m.getOpenSearchPerRegion(r, wg, semaphore, dataReceiver) |
| 313 | } |
| 314 | res, err = servicemap.IsServiceInRegion("grafana", r) |
| 315 | if err != nil { |
| 316 | m.modLog.Error(err) |
| 317 | } |
| 318 | if res { |
| 319 | m.CommandCounter.IncrTotal() |
| 320 | wg.Add(1) |
no test coverage detected