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
}