func()

in internal/resources/providers/awslib/elb_v2/provider_v2.go [32:70]

• 38 lines of code
• 7 McCabe index (conditional complexity)

func (p *Provider) DescribeLoadBalancers(ctx context.Context) ([]awslib.AwsResource, error) {
	p.log.Debug("Fetching Elastic Load Balancers")
	elbs, err := awslib.MultiRegionFetch(ctx, p.clients, func(ctx context.Context, region string, c Client) ([]awslib.AwsResource, error) {
		input := &elbv2.DescribeLoadBalancersInput{}
		all := []types.LoadBalancer{}
		for {
			output, err := c.DescribeLoadBalancers(ctx, input)
			if err != nil {
				return nil, err
			}
			all = append(all, output.LoadBalancers...)
			if output.NextMarker == nil {
				break
			}
			input.Marker = output.NextMarker
		}

		var result []awslib.AwsResource
		for _, item := range all {
			loadBalancer := &ElasticLoadBalancerInfo{
				LoadBalancer: item,
				region:       region,
			}
			listeners, err := p.describeListeners(ctx, region, loadBalancer.GetResourceArn())
			if err != nil {
				p.log.Errorf("Error fetching listeners for %s: %v", loadBalancer.GetResourceArn(), err)
			} else {
				loadBalancer.Listeners = listeners
			}
			result = append(result, loadBalancer)
		}
		return result, nil
	})
	result := lo.Flatten(elbs)
	if err != nil {
		p.log.Debugf("Fetched %d Elastic Load Balancers", len(result))
	}
	return result, err
}