Method scaleOut

commands/clusterscale/command.go:89–118

(autoScalingGroupName string, currentTarget, newTarget uint16)

}

func (c *Command) scaleOut(autoScalingGroupName string, currentTarget, newTarget uint16) error {
	console.UpdatingResource(fmt.Sprintf("Updating desired capacity to %d", newTarget), autoScalingGroupName, true)

	err := c.awsClient.AutoScaling().UpdateAutoScalingGroupCapacity(autoScalingGroupName, 0, newTarget, newTarget)
	if err != nil {
		return fmt.Errorf("Failed to update capacity of EC2 Auto Scaling Group [%s]: %s", autoScalingGroupName, err.Error())
	}

	err = utils.Retry(func() (bool, error) {
		autoScalingGroup, err := c.awsClient.AutoScaling().RetrieveAutoScalingGroup(autoScalingGroupName)
		if err != nil {
			return false, fmt.Errorf("Failed to retrieve EC2 Auto Scaling Group [%s]: %s", autoScalingGroupName, err.Error())
		}
		if autoScalingGroup == nil {
			return false, fmt.Errorf("EC2 Auto Scaling Group [%s] was not found.", autoScalingGroupName)
		}
		if uint16(len(autoScalingGroup.Instances)) == newTarget {
			return false, nil
		}
		return true, nil
	}, time.Second, 5*time.Minute)
	if err != nil {
		return err
	}

	console.Blank()
	//console.Info(fmt.Sprintf("EC2 Auto Scaling Group [%s] now has %d instances.", autoScalingGroupName, newTarget))

	return nil
}

func (c *Command) scaleIn(autoScalingGroupName string, currentTarget, newTarget uint16) error {
	console.UpdatingResource(fmt.Sprintf("Updating desired capacity to %d", newTarget), autoScalingGroupName, true)