func()

in updater/aws.go [81:96]


func (u *updater) listContainerInstances() ([]*string, error) {
	log.Printf("Listing active container instances in cluster %q", u.cluster)
	containerInstances := make([]*string, 0)
	input := &ecs.ListContainerInstancesInput{
		Cluster: &u.cluster,
		Status:  aws.String(ecs.ContainerInstanceStatusActive),
	}
	if err := u.ecs.ListContainerInstancesPages(input, func(output *ecs.ListContainerInstancesOutput, lastpage bool) bool {
		containerInstances = append(containerInstances, output.ContainerInstanceArns...)
		return true
	}); err != nil {
		return nil, fmt.Errorf("failed to list container instances: %w", err)
	}
	log.Printf("Found %d container instances in the cluster", len(containerInstances))
	return containerInstances, nil
}