New resource: aws_autoscalingplans_scaling_plan

aws/internal/service/autoscalingplans/waiter/status.go

@@ -0,0 +1,44 @@
+package waiter
+
+import (
+	"log"
+
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/service/autoscalingplans"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+const (
+	// ScalingPlan NotFound
+	ScalingPlanStatusNotFound = "NotFound"
+
+	// ScalingPlan Unknown
+	ScalingPlanStatusUnknown = "Unknown"
+)
+
+// ScalingPlanStatus fetches the ScalingPlan and its Status
+func ScalingPlanStatus(conn *autoscalingplans.AutoScalingPlans, scalingPlanName string, scalingPlanVersion int) resource.StateRefreshFunc {
+	return func() (interface{}, string, error) {
+		input := &autoscalingplans.DescribeScalingPlansInput{
+			ScalingPlanNames:   aws.StringSlice([]string{scalingPlanName}),
+			ScalingPlanVersion: aws.Int64(int64(scalingPlanVersion)),
+		}
+
+		output, err := conn.DescribeScalingPlans(input)
+
+		if err != nil {
+			return nil, ScalingPlanStatusUnknown, err
+		}
+
+		if len(output.ScalingPlans) == 0 {
+			return "", ScalingPlanStatusNotFound, nil
+		}
+
+		scalingPlan := output.ScalingPlans[0]
+		if statusMessage := aws.StringValue(scalingPlan.StatusMessage); statusMessage != "" {
+			log.Printf("[INFO] Auto Scaling Scaling Plan (%s/%d) status message: %s", scalingPlanName, scalingPlanVersion, statusMessage)
+		}
+
+		return scalingPlan, aws.StringValue(scalingPlan.StatusCode), nil
+	}
+}

aws/internal/service/autoscalingplans/waiter/waiter.go

@@ -0,0 +1,73 @@
+package waiter
+
+import (
+	"time"
+
+	"github.com/aws/aws-sdk-go/service/autoscalingplans"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+const (
+	// Maximum amount of time to wait for a ScalingPlan to return Created
+	ScalingPlanCreatedTimeout = 5 * time.Minute
+
+	// Maximum amount of time to wait for a ScalingPlan to return Deleted
+	ScalingPlanDeletedTimeout = 5 * time.Minute
+
+	// Maximum amount of time to wait for a ScalingPlan to return Updated
+	ScalingPlanUpdatedTimeout = 5 * time.Minute
+)
+
+// ScalingPlanCreated waits for a ScalingPlan to return Created
+func ScalingPlanCreated(conn *autoscalingplans.AutoScalingPlans, scalingPlanName string, scalingPlanVersion int) (*autoscalingplans.ScalingPlan, error) {
+	stateConf := &resource.StateChangeConf{
+		Pending: []string{autoscalingplans.ScalingPlanStatusCodeCreationInProgress},
+		Target:  []string{autoscalingplans.ScalingPlanStatusCodeActive, autoscalingplans.ScalingPlanStatusCodeActiveWithProblems},
+		Refresh: ScalingPlanStatus(conn, scalingPlanName, scalingPlanVersion),
+		Timeout: ScalingPlanCreatedTimeout,
+	}
+
+	outputRaw, err := stateConf.WaitForState()
+
+	if v, ok := outputRaw.(*autoscalingplans.ScalingPlan); ok {
+		return v, err
+	}
+
+	return nil, err
+}
+
+// ScalingPlanDeleted waits for a ScalingPlan to return Deleted
+func ScalingPlanDeleted(conn *autoscalingplans.AutoScalingPlans, scalingPlanName string, scalingPlanVersion int) (*autoscalingplans.ScalingPlan, error) {
+	stateConf := &resource.StateChangeConf{
+		Pending: []string{autoscalingplans.ScalingPlanStatusCodeDeletionInProgress},
+		Target:  []string{ScalingPlanStatusNotFound},
+		Refresh: ScalingPlanStatus(conn, scalingPlanName, scalingPlanVersion),
+		Timeout: ScalingPlanDeletedTimeout,
+	}
+
+	outputRaw, err := stateConf.WaitForState()
+
+	if v, ok := outputRaw.(*autoscalingplans.ScalingPlan); ok {
+		return v, err
+	}
+
+	return nil, err
+}
+
+// ScalingPlanUpdated waits for a ScalingPlan to return Updated
+func ScalingPlanUpdated(conn *autoscalingplans.AutoScalingPlans, scalingPlanName string, scalingPlanVersion int) (*autoscalingplans.ScalingPlan, error) {
+	stateConf := &resource.StateChangeConf{
+		Pending: []string{autoscalingplans.ScalingPlanStatusCodeUpdateInProgress},
+		Target:  []string{autoscalingplans.ScalingPlanStatusCodeActive, autoscalingplans.ScalingPlanStatusCodeActiveWithProblems},
+		Refresh: ScalingPlanStatus(conn, scalingPlanName, scalingPlanVersion),
+		Timeout: ScalingPlanUpdatedTimeout,
+	}
+
+	outputRaw, err := stateConf.WaitForState()
+
+	if v, ok := outputRaw.(*autoscalingplans.ScalingPlan); ok {
+		return v, err
+	}
+
+	return nil, err
+}

aws/provider.go

@@ -430,6 +430,7 @@ func Provider() *schema.Provider {
 			"aws_autoscaling_notification":                            resourceAwsAutoscalingNotification(),
 			"aws_autoscaling_policy":                                  resourceAwsAutoscalingPolicy(),
 			"aws_autoscaling_schedule":                                resourceAwsAutoscalingSchedule(),
+			"aws_autoscalingplans_scaling_plan":                       resourceAwsAutoScalingPlansScalingPlan(),
 			"aws_backup_plan":                                         resourceAwsBackupPlan(),
 			"aws_backup_selection":                                    resourceAwsBackupSelection(),
 			"aws_backup_vault":                                        resourceAwsBackupVault(),