Method getECSWorkloadsPerRegion

aws/workloads.go:370–423

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

}

func (m *WorkloadsModule) getECSWorkloadsPerRegion(r string, wg *sync.WaitGroup, semaphore chan struct{}, dataReceiver chan Workload) {
	defer func() {
		m.CommandCounter.DecrExecuting()
		m.CommandCounter.IncrComplete()
		wg.Done()

	}()
	semaphore <- struct{}{}
	defer func() {
		<-semaphore
	}()

	// Get ECS clusters
	ecsClusters, err := sdk.CachedECSListClusters(m.ECSClient, aws.ToString(m.Caller.Account), r)
	if err != nil {
		m.modLog.Error(err)
	}
	for _, cluster := range ecsClusters {

		// Get ECS tasks
		taskARNs, err := sdk.CachedECSListTasks(m.ECSClient, aws.ToString(m.Caller.Account), r, cluster)
		if err != nil {
			m.modLog.Error(err)
		}

		Tasks, err := sdk.CachedECSDescribeTasks(m.ECSClient, aws.ToString(m.Caller.Account), r, cluster, taskARNs)
		if err != nil {
			m.modLog.Error(err.Error())
			m.CommandCounter.IncrError()
			return
		}

		for _, task := range Tasks {
			var role string
			// Get ECS task definition
			ecsTaskDefinition, err := sdk.CachedECSDescribeTaskDefinition(m.ECSClient, aws.ToString(m.Caller.Account), r, aws.ToString(task.TaskDefinitionArn))
			if err != nil {
				m.modLog.Error(err)
			}
			if ecsTaskDefinition.TaskRoleArn != nil {
				role = aws.ToString(ecsTaskDefinition.TaskRoleArn)
			}

			dataReceiver <- Workload{
				AWSService: "ECS",
				Region:     r,
				Type:       "task",
				Name:       getNameFromARN(aws.ToString(task.TaskDefinitionArn)),
				Arn:        aws.ToString(task.TaskArn),
				Role:       role,
			}
		}
	}
}

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