|
- //
- // autoscaling: This package provides types and functions to interact with the AWS Auto Scale API
- //
- // Depends on https://wiki.ubuntu.com/goamz
- //
-
- package autoscaling
-
- import (
- "encoding/base64"
- "encoding/xml"
- "fmt"
- "log"
- "net/http"
- "net/http/httputil"
- "net/url"
- "sort"
- "strconv"
- "strings"
- "time"
-
- "github.com/goamz/goamz/aws"
- )
-
- const debug = false
-
- var timeNow = time.Now
-
- // AutoScaling contains the details of the AWS region to perform operations against.
- type AutoScaling struct {
- aws.Auth
- aws.Region
- }
-
- // New creates a new AutoScaling Client.
- func New(auth aws.Auth, region aws.Region) *AutoScaling {
- return &AutoScaling{auth, region}
- }
-
- // ----------------------------------------------------------------------------
- // Request dispatching logic.
-
- // Error encapsulates an error returned by the AWS Auto Scaling API.
- //
- // See http://goo.gl/VZGuC for more details.
- type Error struct {
- // HTTP status code (200, 403, ...)
- StatusCode int
- // AutoScaling error code ("UnsupportedOperation", ...)
- Code string
- // The error type
- Type string
- // The human-oriented error message
- Message string
- RequestId string `xml:"RequestID"`
- }
-
- func (err *Error) Error() string {
- if err.Code == "" {
- return err.Message
- }
-
- return fmt.Sprintf("%s (%s)", err.Message, err.Code)
- }
-
- type xmlErrors struct {
- RequestId string `xml:"RequestId"`
- Errors []Error `xml:"Error"`
- }
-
- func (as *AutoScaling) query(params map[string]string, resp interface{}) error {
- params["Version"] = "2011-01-01"
- data := strings.NewReader(multimap(params).Encode())
-
- hreq, err := http.NewRequest("POST", as.Region.AutoScalingEndpoint+"/", data)
- if err != nil {
- return err
- }
-
- hreq.Header.Set("Content-Type", "application/x-www-form-urlencoded; param=value")
-
- token := as.Auth.Token()
- if token != "" {
- hreq.Header.Set("X-Amz-Security-Token", token)
- }
-
- signer := aws.NewV4Signer(as.Auth, "autoscaling", as.Region)
- signer.Sign(hreq)
-
- if debug {
- log.Printf("%v -> {\n", hreq)
- }
- r, err := http.DefaultClient.Do(hreq)
-
- if err != nil {
- log.Printf("Error calling Amazon %v", err)
- return err
- }
-
- defer r.Body.Close()
-
- if debug {
- dump, _ := httputil.DumpResponse(r, true)
- log.Printf("response:\n")
- log.Printf("%v\n}\n", string(dump))
- }
- if r.StatusCode != 200 {
- return buildError(r)
- }
- err = xml.NewDecoder(r.Body).Decode(resp)
- return err
- }
-
- func buildError(r *http.Response) error {
- var (
- err Error
- errors xmlErrors
- )
- xml.NewDecoder(r.Body).Decode(&errors)
- if len(errors.Errors) > 0 {
- err = errors.Errors[0]
- }
-
- err.RequestId = errors.RequestId
- err.StatusCode = r.StatusCode
- if err.Message == "" {
- err.Message = r.Status
- }
- return &err
- }
-
- func multimap(p map[string]string) url.Values {
- q := make(url.Values, len(p))
- for k, v := range p {
- q[k] = []string{v}
- }
- return q
- }
-
- func makeParams(action string) map[string]string {
- params := make(map[string]string)
- params["Action"] = action
- return params
- }
-
- func addParamsList(params map[string]string, label string, ids []string) {
- for i, id := range ids {
- params[label+"."+strconv.Itoa(i+1)] = id
- }
- }
-
- // ----------------------------------------------------------------------------
- // Filtering helper.
-
- // Filter builds filtering parameters to be used in an autoscaling query which supports
- // filtering. For example:
- //
- // filter := NewFilter()
- // filter.Add("architecture", "i386")
- // filter.Add("launch-index", "0")
- // resp, err := as.DescribeTags(filter,nil,nil)
- //
- type Filter struct {
- m map[string][]string
- }
-
- // NewFilter creates a new Filter.
- func NewFilter() *Filter {
- return &Filter{make(map[string][]string)}
- }
-
- // Add appends a filtering parameter with the given name and value(s).
- func (f *Filter) Add(name string, value ...string) {
- f.m[name] = append(f.m[name], value...)
- }
-
- func (f *Filter) addParams(params map[string]string) {
- if f != nil {
- a := make([]string, len(f.m))
- i := 0
- for k := range f.m {
- a[i] = k
- i++
- }
- sort.StringSlice(a).Sort()
- for i, k := range a {
- prefix := "Filters.member." + strconv.Itoa(i+1)
- params[prefix+".Name"] = k
- for j, v := range f.m[k] {
- params[prefix+".Values.member."+strconv.Itoa(j+1)] = v
- }
- }
- }
- }
-
- // ----------------------------------------------------------------------------
- // Auto Scaling base types and related functions.
-
- // SimpleResp is the basic response from most actions.
- type SimpleResp struct {
- XMLName xml.Name
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // EnabledMetric encapsulates a metric associated with an Auto Scaling Group
- //
- // See http://goo.gl/hXiH17 for more details
- type EnabledMetric struct {
- Granularity string `xml:"Granularity"` // The granularity of the enabled metric.
- Metric string `xml:"Metric"` // The name of the enabled metric.
- }
-
- // Instance encapsulates an instance type as returned by the Auto Scaling API
- //
- // See http://goo.gl/NwBxGh and http://goo.gl/OuoqhS for more details.
- type Instance struct {
- // General instance information
- AutoScalingGroupName string `xml:"AutoScalingGroupName"`
- AvailabilityZone string `xml:"AvailabilityZone"`
- HealthStatus string `xml:"HealthStatus"`
- InstanceId string `xml:"InstanceId"`
- LaunchConfigurationName string `xml:"LaunchConfigurationName"`
- LifecycleState string `xml:"LifecycleState"`
- }
-
- // SuspenedProcess encapsulates an Auto Scaling process that has been suspended
- //
- // See http://goo.gl/iObPgF for more details
- type SuspendedProcess struct {
- ProcessName string `xml:"ProcessName"`
- SuspensionReason string `xml:"SuspensionReason"`
- }
-
- // Tag encapsulates tag applied to an Auto Scaling group.
- //
- // See http://goo.gl/MG1hqs for more details
- type Tag struct {
- Key string `xml:"Key"`
- PropagateAtLaunch bool `xml:"PropagateAtLaunch"` // Specifies whether the new tag will be applied to instances launched after the tag is created
- ResourceId string `xml:"ResourceId"` // the name of the Auto Scaling group - not required if creating ASG
- ResourceType string `xml:"ResourceType"` // currently only auto-scaling-group is supported - not required if creating ASG
- Value string `xml:"Value"`
- }
-
- // AutoScalingGroup encapsulates an Auto Scaling Group object
- //
- // See http://goo.gl/fJdYhg for more details.
- type AutoScalingGroup struct {
- AutoScalingGroupARN string `xml:"AutoScalingGroupARN"`
- AutoScalingGroupName string `xml:"AutoScalingGroupName"`
- AvailabilityZones []string `xml:"AvailabilityZones>member"`
- CreatedTime time.Time `xml:"CreatedTime"`
- DefaultCooldown int `xml:"DefaultCooldown"`
- DesiredCapacity int `xml:"DesiredCapacity"`
- EnabledMetrics []EnabledMetric `xml:"EnabledMetric>member"`
- HealthCheckGracePeriod int `xml:"HealthCheckGracePeriod"`
- HealthCheckType string `xml:"HealthCheckType"`
- Instances []Instance `xml:"Instances>member"`
- LaunchConfigurationName string `xml:"LaunchConfigurationName"`
- LoadBalancerNames []string `xml:"LoadBalancerNames>member"`
- MaxSize int `xml:"MaxSize"`
- MinSize int `xml:"MinSize"`
- PlacementGroup string `xml:"PlacementGroup"`
- Status string `xml:"Status"`
- SuspendedProcesses []SuspendedProcess `xml:"SuspendedProcesses>member"`
- Tags []Tag `xml:"Tags>member"`
- TerminationPolicies []string `xml:"TerminationPolicies>member"`
- VPCZoneIdentifier string `xml:"VPCZoneIdentifier"`
- }
-
- // CreateAutoScalingGroupParams type encapsulates options for the respective request.
- //
- // See http://goo.gl/3S13Bv for more details.
- type CreateAutoScalingGroupParams struct {
- AutoScalingGroupName string
- AvailabilityZones []string
- DefaultCooldown int
- DesiredCapacity int
- HealthCheckGracePeriod int
- HealthCheckType string
- InstanceId string
- LaunchConfigurationName string
- LoadBalancerNames []string
- MaxSize int
- MinSize int
- PlacementGroup string
- Tags []Tag
- TerminationPolicies []string
- VPCZoneIdentifier string
- }
-
- // AttachInstances Attach running instances to an autoscaling group
- //
- // See http://goo.gl/zDZbuQ for more details.
- func (as *AutoScaling) AttachInstances(name string, instanceIds []string) (resp *SimpleResp, err error) {
- params := makeParams("AttachInstances")
- params["AutoScalingGroupName"] = name
-
- for i, id := range instanceIds {
- key := fmt.Sprintf("InstanceIds.member.%d", i+1)
- params[key] = id
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // CreateAutoScalingGroup creates an Auto Scaling Group on AWS
- //
- // Required params: AutoScalingGroupName, MinSize, MaxSize
- //
- // See http://goo.gl/3S13Bv for more details.
- func (as *AutoScaling) CreateAutoScalingGroup(options *CreateAutoScalingGroupParams) (
- resp *SimpleResp, err error) {
- params := makeParams("CreateAutoScalingGroup")
-
- params["AutoScalingGroupName"] = options.AutoScalingGroupName
- params["MaxSize"] = strconv.Itoa(options.MaxSize)
- params["MinSize"] = strconv.Itoa(options.MinSize)
- params["DesiredCapacity"] = strconv.Itoa(options.DesiredCapacity)
-
- if options.DefaultCooldown > 0 {
- params["DefaultCooldown"] = strconv.Itoa(options.DefaultCooldown)
- }
- if options.HealthCheckGracePeriod > 0 {
- params["HealthCheckGracePeriod"] = strconv.Itoa(options.HealthCheckGracePeriod)
- }
- if options.HealthCheckType != "" {
- params["HealthCheckType"] = options.HealthCheckType
- }
- if options.InstanceId != "" {
- params["InstanceId"] = options.InstanceId
- }
- if options.LaunchConfigurationName != "" {
- params["LaunchConfigurationName"] = options.LaunchConfigurationName
- }
- if options.PlacementGroup != "" {
- params["PlacementGroup"] = options.PlacementGroup
- }
- if options.VPCZoneIdentifier != "" {
- params["VPCZoneIdentifier"] = options.VPCZoneIdentifier
- }
- if len(options.LoadBalancerNames) > 0 {
- addParamsList(params, "LoadBalancerNames.member", options.LoadBalancerNames)
- }
- if len(options.AvailabilityZones) > 0 {
- addParamsList(params, "AvailabilityZones.member", options.AvailabilityZones)
- }
- if len(options.TerminationPolicies) > 0 {
- addParamsList(params, "TerminationPolicies.member", options.TerminationPolicies)
- }
- for i, t := range options.Tags {
- key := "Tags.member.%d.%s"
- index := i + 1
- params[fmt.Sprintf(key, index, "Key")] = t.Key
- params[fmt.Sprintf(key, index, "Value")] = t.Value
- params[fmt.Sprintf(key, index, "PropagateAtLaunch")] = strconv.FormatBool(t.PropagateAtLaunch)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // EBS represents the AWS EBS volume data type
- //
- // See http://goo.gl/nDUL2h for more details
- type EBS struct {
- DeleteOnTermination bool `xml:"DeleteOnTermination"`
- Iops int `xml:"Iops"`
- SnapshotId string `xml:"SnapshotId"`
- VolumeSize int `xml:"VolumeSize"`
- VolumeType string `xml:"VolumeType"`
- }
-
- // BlockDeviceMapping represents the association of a block device with ebs volume.
- //
- // See http://goo.gl/wEGwkU for more details.
- type BlockDeviceMapping struct {
- DeviceName string `xml:"DeviceName"`
- Ebs EBS `xml:"Ebs"`
- NoDevice bool `xml:"NoDevice"`
- VirtualName string `xml:"VirtualName"`
- }
-
- // InstanceMonitoring data type
- //
- // See http://goo.gl/TfaPwz for more details
- type InstanceMonitoring struct {
- Enabled bool `xml:"Enabled"`
- }
-
- // LaunchConfiguration encapsulates the LaunchConfiguration Data Type
- //
- // See http://goo.gl/TOJunp
- type LaunchConfiguration struct {
- AssociatePublicIpAddress bool `xml:"AssociatePublicIpAddress"`
- BlockDeviceMappings []BlockDeviceMapping `xml:"BlockDeviceMappings>member"`
- CreatedTime time.Time `xml:"CreatedTime"`
- EbsOptimized bool `xml:"EbsOptimized"`
- IamInstanceProfile string `xml:"IamInstanceProfile"`
- ImageId string `xml:"ImageId"`
- InstanceId string `xml:"InstanceId"`
- InstanceMonitoring InstanceMonitoring `xml:"InstanceMonitoring"`
- InstanceType string `xml:"InstanceType"`
- KernelId string `xml:"KernelId"`
- KeyName string `xml:"KeyName"`
- LaunchConfigurationARN string `xml:"LaunchConfigurationARN"`
- LaunchConfigurationName string `xml:"LaunchConfigurationName"`
- RamdiskId string `xml:"RamdiskId"`
- SecurityGroups []string `xml:"SecurityGroups>member"`
- SpotPrice string `xml:"SpotPrice"`
- UserData string `xml:"UserData"`
- }
-
- // CreateLaunchConfiguration creates a launch configuration
- //
- // Required params: AutoScalingGroupName, MinSize, MaxSize
- //
- // See http://goo.gl/8e0BSF for more details.
- func (as *AutoScaling) CreateLaunchConfiguration(lc *LaunchConfiguration) (
- resp *SimpleResp, err error) {
-
- var b64 = base64.StdEncoding
-
- params := makeParams("CreateLaunchConfiguration")
- params["LaunchConfigurationName"] = lc.LaunchConfigurationName
-
- if lc.AssociatePublicIpAddress {
- params["AssociatePublicIpAddress"] = strconv.FormatBool(lc.AssociatePublicIpAddress)
- }
- if lc.EbsOptimized {
- params["EbsOptimized"] = strconv.FormatBool(lc.EbsOptimized)
- }
- if lc.IamInstanceProfile != "" {
- params["IamInstanceProfile"] = lc.IamInstanceProfile
- }
- if lc.ImageId != "" {
- params["ImageId"] = lc.ImageId
- }
- if lc.InstanceId != "" {
- params["InstanceId"] = lc.InstanceId
- }
- if lc.InstanceMonitoring != (InstanceMonitoring{}) {
- params["InstanceMonitoring.Enabled"] = strconv.FormatBool(lc.InstanceMonitoring.Enabled)
- }
- if lc.InstanceType != "" {
- params["InstanceType"] = lc.InstanceType
- }
- if lc.KernelId != "" {
- params["KernelId"] = lc.KernelId
- }
- if lc.KeyName != "" {
- params["KeyName"] = lc.KeyName
- }
- if lc.RamdiskId != "" {
- params["RamdiskId"] = lc.RamdiskId
- }
- if lc.SpotPrice != "" {
- params["SpotPrice"] = lc.SpotPrice
- }
- if lc.UserData != "" {
- params["UserData"] = b64.EncodeToString([]byte(lc.UserData))
- }
-
- // Add our block device mappings
- for i, bdm := range lc.BlockDeviceMappings {
- key := "BlockDeviceMappings.member.%d.%s"
- index := i + 1
- params[fmt.Sprintf(key, index, "DeviceName")] = bdm.DeviceName
- params[fmt.Sprintf(key, index, "VirtualName")] = bdm.VirtualName
-
- if bdm.NoDevice {
- params[fmt.Sprintf(key, index, "NoDevice")] = "true"
- }
-
- if bdm.Ebs != (EBS{}) {
- key := "BlockDeviceMappings.member.%d.Ebs.%s"
-
- // Defaults to true
- params[fmt.Sprintf(key, index, "DeleteOnTermination")] = strconv.FormatBool(bdm.Ebs.DeleteOnTermination)
-
- if bdm.Ebs.Iops > 0 {
- params[fmt.Sprintf(key, index, "Iops")] = strconv.Itoa(bdm.Ebs.Iops)
- }
- if bdm.Ebs.SnapshotId != "" {
- params[fmt.Sprintf(key, index, "SnapshotId")] = bdm.Ebs.SnapshotId
- }
- if bdm.Ebs.VolumeSize > 0 {
- params[fmt.Sprintf(key, index, "VolumeSize")] = strconv.Itoa(bdm.Ebs.VolumeSize)
- }
- if bdm.Ebs.VolumeType != "" {
- params[fmt.Sprintf(key, index, "VolumeType")] = bdm.Ebs.VolumeType
- }
- }
- }
-
- if len(lc.SecurityGroups) > 0 {
- addParamsList(params, "SecurityGroups.member", lc.SecurityGroups)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // CreateOrUpdateTags creates or updates Auto Scaling Group Tags
- //
- // See http://goo.gl/e1UIXb for more details.
- func (as *AutoScaling) CreateOrUpdateTags(tags []Tag) (resp *SimpleResp, err error) {
- params := makeParams("CreateOrUpdateTags")
-
- for i, t := range tags {
- key := "Tags.member.%d.%s"
- index := i + 1
- params[fmt.Sprintf(key, index, "Key")] = t.Key
- params[fmt.Sprintf(key, index, "Value")] = t.Value
- params[fmt.Sprintf(key, index, "PropagateAtLaunch")] = strconv.FormatBool(t.PropagateAtLaunch)
- params[fmt.Sprintf(key, index, "ResourceId")] = t.ResourceId
- if t.ResourceType != "" {
- params[fmt.Sprintf(key, index, "ResourceType")] = t.ResourceType
- } else {
- params[fmt.Sprintf(key, index, "ResourceType")] = "auto-scaling-group"
- }
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- type CompleteLifecycleActionParams struct {
- AutoScalingGroupName string
- LifecycleActionResult string
- LifecycleActionToken string
- LifecycleHookName string
- }
-
- // CompleteLifecycleAction completes the lifecycle action for the associated token initiated under the given lifecycle hook with the specified result.
- //
- // Part of the basic sequence for adding a lifecycle hook to an Auto Scaling group:
- // 1) Create a notification target (SQS queue || SNS Topic)
- // 2) Create an IAM role to allow the ASG topublish lifecycle notifications to the designated SQS queue or SNS topic
- // 3) Create the lifecycle hook. You can create a hook that acts when instances launch or when instances terminate
- // 4) If necessary, record the lifecycle action heartbeat to keep the instance in a pending state
- // 5) ***Complete the lifecycle action***
- //
- // See http://goo.gl/k4fl0p for more details
- func (as *AutoScaling) CompleteLifecycleAction(options *CompleteLifecycleActionParams) (
- resp *SimpleResp, err error) {
- params := makeParams("CompleteLifecycleAction")
-
- params["AutoScalingGroupName"] = options.AutoScalingGroupName
- params["LifecycleActionResult"] = options.LifecycleActionResult
- params["LifecycleActionToken"] = options.LifecycleActionToken
- params["LifecycleHookName"] = options.LifecycleHookName
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DeleteAutoScalingGroup deletes an Auto Scaling Group
- //
- // See http://goo.gl/us7VSffor for more details.
- func (as *AutoScaling) DeleteAutoScalingGroup(asgName string, forceDelete bool) (
- resp *SimpleResp, err error) {
- params := makeParams("DeleteAutoScalingGroup")
- params["AutoScalingGroupName"] = asgName
-
- if forceDelete {
- params["ForceDelete"] = "true"
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DeleteLaunchConfiguration deletes a Launch Configuration
- //
- // See http://goo.gl/xksfyR for more details.
- func (as *AutoScaling) DeleteLaunchConfiguration(name string) (resp *SimpleResp, err error) {
- params := makeParams("DeleteLaunchConfiguration")
- params["LaunchConfigurationName"] = name
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DeleteLifecycleHook eletes the specified lifecycle hook.
- // If there are any outstanding lifecycle actions, they are completed first
- //
- // See http://goo.gl/MwX1vG for more details.
- func (as *AutoScaling) DeleteLifecycleHook(asgName, lifecycleHookName string) (resp *SimpleResp, err error) {
- params := makeParams("DeleteLifecycleHook")
- params["AutoScalingGroupName"] = asgName
- params["LifecycleHookName"] = lifecycleHookName
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DeleteNotificationConfiguration deletes notifications created by PutNotificationConfiguration.
- //
- // See http://goo.gl/jTqoYz for more details
- func (as *AutoScaling) DeleteNotificationConfiguration(asgName string, topicARN string) (
- resp *SimpleResp, err error) {
- params := makeParams("DeleteNotificationConfiguration")
- params["AutoScalingGroupName"] = asgName
- params["TopicARN"] = topicARN
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DeletePolicy deletes a policy created by PutScalingPolicy.
- //
- // policyName might be the policy name or ARN
- //
- // See http://goo.gl/aOQPH2 for more details
- func (as *AutoScaling) DeletePolicy(asgName string, policyName string) (resp *SimpleResp, err error) {
- params := makeParams("DeletePolicy")
- params["AutoScalingGroupName"] = asgName
- params["PolicyName"] = policyName
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DeleteScheduledAction deletes a scheduled action previously created using the PutScheduledUpdateGroupAction.
- //
- // See http://goo.gl/Zss9CH for more details
- func (as *AutoScaling) DeleteScheduledAction(asgName string, scheduledActionName string) (resp *SimpleResp, err error) {
- params := makeParams("DeleteScheduledAction")
- params["AutoScalingGroupName"] = asgName
- params["ScheduledActionName"] = scheduledActionName
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DeleteTags deletes autoscaling group tags
- //
- // See http://goo.gl/o8HzAk for more details.
- func (as *AutoScaling) DeleteTags(tags []Tag) (resp *SimpleResp, err error) {
- params := makeParams("DeleteTags")
-
- for i, t := range tags {
- key := "Tags.member.%d.%s"
- index := i + 1
- params[fmt.Sprintf(key, index, "Key")] = t.Key
- params[fmt.Sprintf(key, index, "Value")] = t.Value
- params[fmt.Sprintf(key, index, "PropagateAtLaunch")] = strconv.FormatBool(t.PropagateAtLaunch)
- params[fmt.Sprintf(key, index, "ResourceId")] = t.ResourceId
- params[fmt.Sprintf(key, index, "ResourceType")] = "auto-scaling-group"
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- //DescribeAccountLimits response wrapper
- //
- // See http://goo.gl/tKsMN0 for more details.
- type DescribeAccountLimitsResp struct {
- MaxNumberOfAutoScalingGroups int `xml:"DescribeAccountLimitsResult>MaxNumberOfAutoScalingGroups"`
- MaxNumberOfLaunchConfigurations int `xml:"DescribeAccountLimitsResult>MaxNumberOfLaunchConfigurations"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeAccountLimits - Returns the limits for the Auto Scaling resources currently allowed for your AWS account.
- //
- // See http://goo.gl/tKsMN0 for more details.
- func (as *AutoScaling) DescribeAccountLimits() (resp *DescribeAccountLimitsResp, err error) {
- params := makeParams("DescribeAccountLimits")
-
- resp = new(DescribeAccountLimitsResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // AdjustmentType specifies whether the PutScalingPolicy ScalingAdjustment parameter is an absolute number or a percentage of the current capacity.
- //
- // See http://goo.gl/tCFqeL for more details
- type AdjustmentType struct {
- AdjustmentType string //Valid values are ChangeInCapacity, ExactCapacity, and PercentChangeInCapacity.
- }
-
- //DescribeAdjustmentTypes response wrapper
- //
- // See http://goo.gl/hGx3Pc for more details.
- type DescribeAdjustmentTypesResp struct {
- AdjustmentTypes []AdjustmentType `xml:"DescribeAdjustmentTypesResult>AdjustmentTypes>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeAdjustmentTypes returns policy adjustment types for use in the PutScalingPolicy action.
- //
- // See http://goo.gl/hGx3Pc for more details.
- func (as *AutoScaling) DescribeAdjustmentTypes() (resp *DescribeAdjustmentTypesResp, err error) {
- params := makeParams("DescribeAdjustmentTypes")
-
- resp = new(DescribeAdjustmentTypesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DescribeAutoScalingGroups response wrapper
- //
- // See http://goo.gl/nW74Ut for more details.
- type DescribeAutoScalingGroupsResp struct {
- AutoScalingGroups []AutoScalingGroup `xml:"DescribeAutoScalingGroupsResult>AutoScalingGroups>member"`
- NextToken string `xml:"DescribeAutoScalingGroupsResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeAutoScalingGroups returns a full description of each Auto Scaling group in the given list
- // If no autoscaling groups are provided, returns the details of all autoscaling groups
- // Supports pagination by using the returned "NextToken" parameter for subsequent calls
- //
- // See http://goo.gl/nW74Ut for more details.
- func (as *AutoScaling) DescribeAutoScalingGroups(names []string, maxRecords int, nextToken string) (
- resp *DescribeAutoScalingGroupsResp, err error) {
- params := makeParams("DescribeAutoScalingGroups")
-
- if maxRecords != 0 {
- params["MaxRecords"] = strconv.Itoa(maxRecords)
- }
- if nextToken != "" {
- params["NextToken"] = nextToken
- }
- if len(names) > 0 {
- addParamsList(params, "AutoScalingGroupNames.member", names)
- }
-
- resp = new(DescribeAutoScalingGroupsResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DescribeAutoScalingInstances response wrapper
- //
- // See http://goo.gl/ckzORt for more details.
- type DescribeAutoScalingInstancesResp struct {
- AutoScalingInstances []Instance `xml:"DescribeAutoScalingInstancesResult>AutoScalingInstances>member"`
- NextToken string `xml:"DescribeAutoScalingInstancesResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeAutoScalingInstances returns a description of each Auto Scaling instance in the InstanceIds list.
- // If a list is not provided, the service returns the full details of all instances up to a maximum of 50
- // By default, the service returns a list of 20 items.
- // Supports pagination by using the returned "NextToken" parameter for subsequent calls
- //
- // See http://goo.gl/ckzORt for more details.
- func (as *AutoScaling) DescribeAutoScalingInstances(ids []string, maxRecords int, nextToken string) (
- resp *DescribeAutoScalingInstancesResp, err error) {
- params := makeParams("DescribeAutoScalingInstances")
-
- if maxRecords != 0 {
- params["MaxRecords"] = strconv.Itoa(maxRecords)
- }
- if nextToken != "" {
- params["NextToken"] = nextToken
- }
- if len(ids) > 0 {
- addParamsList(params, "InstanceIds.member", ids)
- }
-
- resp = new(DescribeAutoScalingInstancesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DescribeAutoScalingNotificationTypes response wrapper
- //
- // See http://goo.gl/pmLIoE for more details.
- type DescribeAutoScalingNotificationTypesResp struct {
- AutoScalingNotificationTypes []string `xml:"DescribeAutoScalingNotificationTypesResult>AutoScalingNotificationTypes>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeAutoScalingNotificationTypes returns a list of all notification types that are supported by Auto Scaling
- //
- // See http://goo.gl/pmLIoE for more details.
- func (as *AutoScaling) DescribeAutoScalingNotificationTypes() (resp *DescribeAutoScalingNotificationTypesResp, err error) {
- params := makeParams("DescribeAutoScalingNotificationTypes")
-
- resp = new(DescribeAutoScalingNotificationTypesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DescribeLaunchConfigurationResp defines the basic response structure for launch configuration
- // requests
- //
- // See http://goo.gl/y31YYE for more details.
- type DescribeLaunchConfigurationsResp struct {
- LaunchConfigurations []LaunchConfiguration `xml:"DescribeLaunchConfigurationsResult>LaunchConfigurations>member"`
- NextToken string `xml:"DescribeLaunchConfigurationsResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeLaunchConfigurations returns details about the launch configurations supplied in
- // the list. If the list is nil, information is returned about all launch configurations in the
- // region.
- //
- // See http://goo.gl/y31YYE for more details.
- func (as *AutoScaling) DescribeLaunchConfigurations(names []string, maxRecords int, nextToken string) (
- resp *DescribeLaunchConfigurationsResp, err error) {
- params := makeParams("DescribeLaunchConfigurations")
-
- if maxRecords != 0 {
- params["MaxRecords"] = strconv.Itoa(maxRecords)
- }
- if nextToken != "" {
- params["NextToken"] = nextToken
- }
- if len(names) > 0 {
- addParamsList(params, "LaunchConfigurationNames.member", names)
- }
-
- resp = new(DescribeLaunchConfigurationsResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
-
- return resp, nil
- }
-
- // DescribeLifecycleHookTypesResult wraps a DescribeLifecycleHookTypes response
- //
- // See http://goo.gl/qiAH31 for more details.
- type DescribeLifecycleHookTypesResult struct {
- LifecycleHookTypes []string `xml:"DescribeLifecycleHookTypesResult>LifecycleHookTypes>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeLifecycleHookTypes describes the available types of lifecycle hooks
- //
- // See http://goo.gl/E9IBtY for more information
- func (as *AutoScaling) DescribeLifecycleHookTypes() (
- resp *DescribeLifecycleHookTypesResult, err error) {
- params := makeParams("DescribeLifecycleHookTypes")
-
- resp = new(DescribeLifecycleHookTypesResult)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // LifecycleHook represents a lifecyclehook object
- //
- // See http://goo.gl/j62Iqu for more information
- type LifecycleHook struct {
- AutoScalingGroupName string `xml:"AutoScalingGroupName"`
- DefaultResult string `xml:"DefaultResult"`
- GlobalTimeout int `xml:"GlobalTimeout"`
- HeartbeatTimeout int `xml:"HeartbeatTimeout"`
- LifecycleHookName string `xml:"LifecycleHookName"`
- LifecycleTransition string `xml:"LifecycleTransition"`
- NotificationMetadata string `xml:"NotificationMetadata"`
- NotificationTargetARN string `xml:"NotificationTargetARN"`
- RoleARN string `xml:"RoleARN"`
- }
-
- // DescribeLifecycleHooks wraps a DescribeLifecycleHooks response
- //
- // See http://goo.gl/wQkWiz for more details.
- type DescribeLifecycleHooksResult struct {
- LifecycleHooks []string `xml:"DescribeLifecycleHooksResult>LifecycleHooks>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeLifecycleHooks describes the lifecycle hooks that currently belong to the specified Auto Scaling group
- //
- // See http://goo.gl/wQkWiz for more information
- func (as *AutoScaling) DescribeLifecycleHooks(asgName string, hookNames []string) (
- resp *DescribeLifecycleHooksResult, err error) {
- params := makeParams("DescribeLifecycleHooks")
- params["AutoScalingGroupName"] = asgName
-
- if len(hookNames) > 0 {
- addParamsList(params, "LifecycleHookNames.member", hookNames)
- }
-
- resp = new(DescribeLifecycleHooksResult)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // MetricGranularity encapsulates the MetricGranularityType
- //
- // See http://goo.gl/WJ82AA for more details
- type MetricGranularity struct {
- Granularity string `xml:"Granularity"`
- }
-
- //MetricCollection encapsulates the MetricCollectionType
- //
- // See http://goo.gl/YrEG6h for more details
- type MetricCollection struct {
- Metric string `xml:"Metric"`
- }
-
- // DescribeMetricCollectionTypesResp response wrapper
- //
- // See http://goo.gl/UyYc3i for more details.
- type DescribeMetricCollectionTypesResp struct {
- Granularities []MetricGranularity `xml:"DescribeMetricCollectionTypesResult>Granularities>member"`
- Metrics []MetricCollection `xml:"DescribeMetricCollectionTypesResult>Metrics>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeMetricCollectionTypes returns a list of metrics and a corresponding list of granularities for each metric
- //
- // See http://goo.gl/UyYc3i for more details.
- func (as *AutoScaling) DescribeMetricCollectionTypes() (resp *DescribeMetricCollectionTypesResp, err error) {
- params := makeParams("DescribeMetricCollectionTypes")
-
- resp = new(DescribeMetricCollectionTypesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // NotificationConfiguration encapsulates the NotificationConfigurationType
- //
- // See http://goo.gl/M8xYOQ for more details
- type NotificationConfiguration struct {
- AutoScalingGroupName string `xml:"AutoScalingGroupName"`
- NotificationType string `xml:"NotificationType"`
- TopicARN string `xml:"TopicARN"`
- }
-
- // DescribeNotificationConfigurations response wrapper
- //
- // See http://goo.gl/qiAH31 for more details.
- type DescribeNotificationConfigurationsResp struct {
- NotificationConfigurations []NotificationConfiguration `xml:"DescribeNotificationConfigurationsResult>NotificationConfigurations>member"`
- NextToken string `xml:"DescribeNotificationConfigurationsResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeNotificationConfigurations returns a list of notification actions associated with Auto Scaling groups for specified events.
- // Supports pagination by using the returned "NextToken" parameter for subsequent calls
- //
- // http://goo.gl/qiAH31 for more details.
- func (as *AutoScaling) DescribeNotificationConfigurations(asgNames []string, maxRecords int, nextToken string) (
- resp *DescribeNotificationConfigurationsResp, err error) {
- params := makeParams("DescribeNotificationConfigurations")
-
- if maxRecords != 0 {
- params["MaxRecords"] = strconv.Itoa(maxRecords)
- }
- if nextToken != "" {
- params["NextToken"] = nextToken
- }
- if len(asgNames) > 0 {
- addParamsList(params, "AutoScalingGroupNames.member", asgNames)
- }
-
- resp = new(DescribeNotificationConfigurationsResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // Alarm encapsulates the Alarm data type.
- //
- // See http://goo.gl/Q0uPAB for more details
- type Alarm struct {
- AlarmARN string `xml:"AlarmARN"`
- AlarmName string `xml:"AlarmName"`
- }
-
- // ScalingPolicy encapsulates the ScalingPolicyType
- //
- // See http://goo.gl/BYAT18 for more details
- type ScalingPolicy struct {
- AdjustmentType string `xml:"AdjustmentType"` // ChangeInCapacity, ExactCapacity, and PercentChangeInCapacity
- Alarms []Alarm `xml:"Alarms>member"` // A list of CloudWatch Alarms related to the policy
- AutoScalingGroupName string `xml:"AutoScalingGroupName"`
- Cooldown int `xml:"Cooldown"`
- MinAdjustmentStep int `xml:"MinAdjustmentStep"` // Changes the DesiredCapacity of ASG by at least the specified number of instances.
- PolicyARN string `xml:"PolicyARN"`
- PolicyName string `xml:"PolicyName"`
- ScalingAdjustment int `xml:"ScalingAdjustment"`
- }
-
- // DescribePolicies response wrapper
- //
- // http://goo.gl/bN7A9T for more details.
- type DescribePoliciesResp struct {
- ScalingPolicies []ScalingPolicy `xml:"DescribePoliciesResult>ScalingPolicies>member"`
- NextToken string `xml:"DescribePoliciesResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribePolicies returns descriptions of what each policy does.
- // Supports pagination by using the returned "NextToken" parameter for subsequent calls
- //
- // http://goo.gl/bN7A9Tfor more details.
- func (as *AutoScaling) DescribePolicies(asgName string, policyNames []string, maxRecords int, nextToken string) (
- resp *DescribePoliciesResp, err error) {
- params := makeParams("DescribePolicies")
-
- if asgName != "" {
- params["AutoScalingGroupName"] = asgName
- }
- if maxRecords != 0 {
- params["MaxRecords"] = strconv.Itoa(maxRecords)
- }
- if nextToken != "" {
- params["NextToken"] = nextToken
- }
- if len(policyNames) > 0 {
- addParamsList(params, "PolicyNames.member", policyNames)
- }
-
- resp = new(DescribePoliciesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // Activity encapsulates the Activity data type
- //
- // See http://goo.gl/fRaVi1 for more details
- type Activity struct {
- ActivityId string `xml:"ActivityId"`
- AutoScalingGroupName string `xml:"AutoScalingGroupName"`
- Cause string `xml:"Cause"`
- Description string `xml:"Description"`
- Details string `xml:"Details"`
- EndTime time.Time `xml:"EndTime"`
- Progress int `xml:"Progress"`
- StartTime time.Time `xml:"StartTime"`
- StatusCode string `xml:"StatusCode"`
- StatusMessage string `xml:"StatusMessage"`
- }
-
- // DescribeScalingActivities response wrapper
- //
- // http://goo.gl/noOXIC for more details.
- type DescribeScalingActivitiesResp struct {
- Activities []Activity `xml:"DescribeScalingActivitiesResult>Activities>member"`
- NextToken string `xml:"DescribeScalingActivitiesResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeScalingActivities returns the scaling activities for the specified Auto Scaling group.
- // Supports pagination by using the returned "NextToken" parameter for subsequent calls
- //
- // http://goo.gl/noOXIC more details.
- func (as *AutoScaling) DescribeScalingActivities(asgName string, activityIds []string, maxRecords int, nextToken string) (
- resp *DescribeScalingActivitiesResp, err error) {
- params := makeParams("DescribeScalingActivities")
-
- if asgName != "" {
- params["AutoScalingGroupName"] = asgName
- }
- if maxRecords != 0 {
- params["MaxRecords"] = strconv.Itoa(maxRecords)
- }
- if nextToken != "" {
- params["NextToken"] = nextToken
- }
- if len(activityIds) > 0 {
- addParamsList(params, "ActivityIds.member", activityIds)
- }
-
- resp = new(DescribeScalingActivitiesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // ProcessType encapsulates the Auto Scaling process data type
- //
- // See http://goo.gl/9BvNik for more details.
- type ProcessType struct {
- ProcessName string `xml:"ProcessName"`
- }
-
- // DescribeScalingProcessTypes response wrapper
- //
- // See http://goo.gl/rkp2tw for more details.
- type DescribeScalingProcessTypesResp struct {
- Processes []ProcessType `xml:"DescribeScalingProcessTypesResult>Processes>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeScalingProcessTypes returns scaling process types for use in the ResumeProcesses and SuspendProcesses actions.
- //
- // See http://goo.gl/rkp2tw for more details.
- func (as *AutoScaling) DescribeScalingProcessTypes() (resp *DescribeScalingProcessTypesResp, err error) {
- params := makeParams("DescribeScalingProcessTypes")
-
- resp = new(DescribeScalingProcessTypesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // ScheduledUpdateGroupAction contains the information to be used in a scheduled update to an
- // AutoScalingGroup
- //
- // See http://goo.gl/z2Kfxe for more details
- type ScheduledUpdateGroupAction struct {
- AutoScalingGroupName string `xml:"AutoScalingGroupName"`
- DesiredCapacity int `xml:"DesiredCapacity"`
- EndTime time.Time `xml:"EndTime"`
- MaxSize int `xml:"MaxSize"`
- MinSize int `xml:"MinSize"`
- Recurrence string `xml:"Recurrence"`
- ScheduledActionARN string `xml:"ScheduledActionARN"`
- ScheduledActionName string `xml:"ScheduledActionName"`
- StartTime time.Time `xml:"StartTime"`
- Time time.Time `xml:"Time"`
- }
-
- // DescribeScheduledActionsResult contains the response from a DescribeScheduledActions.
- //
- // See http://goo.gl/zqrJLx for more details.
- type DescribeScheduledActionsResult struct {
- ScheduledUpdateGroupActions []ScheduledUpdateGroupAction `xml:"DescribeScheduledActionsResult>ScheduledUpdateGroupActions>member"`
- NextToken string `xml:"DescribeScheduledActionsResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // ScheduledActionsRequestParams contains the items that can be specified when making
- // a ScheduledActions request
- type DescribeScheduledActionsParams struct {
- AutoScalingGroupName string
- EndTime time.Time
- MaxRecords int
- ScheduledActionNames []string
- StartTime time.Time
- NextToken string
- }
-
- // DescribeScheduledActions returns a list of the current scheduled actions. If the
- // AutoScalingGroup name is provided it will list all the scheduled actions for that group.
- //
- // See http://goo.gl/zqrJLx for more details.
- func (as *AutoScaling) DescribeScheduledActions(options *DescribeScheduledActionsParams) (
- resp *DescribeScheduledActionsResult, err error) {
- params := makeParams("DescribeScheduledActions")
-
- if options.AutoScalingGroupName != "" {
- params["AutoScalingGroupName"] = options.AutoScalingGroupName
- }
- if !options.StartTime.IsZero() {
- params["StartTime"] = options.StartTime.Format(time.RFC3339)
- }
- if !options.EndTime.IsZero() {
- params["EndTime"] = options.EndTime.Format(time.RFC3339)
- }
- if options.MaxRecords > 0 {
- params["MaxRecords"] = strconv.Itoa(options.MaxRecords)
- }
- if options.NextToken != "" {
- params["NextToken"] = options.NextToken
- }
- if len(options.ScheduledActionNames) > 0 {
- addParamsList(params, "ScheduledActionNames.member", options.ScheduledActionNames)
- }
-
- resp = new(DescribeScheduledActionsResult)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DescribeTags response wrapper
- //
- // See http://goo.gl/ZTEU3G for more details.
- type DescribeTagsResp struct {
- Tags []Tag `xml:"DescribeTagsResult>Tags>member"`
- NextToken string `xml:"DescribeTagsResult>NextToken"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeTags lists the Auto Scaling group tags.
- // Supports pagination by using the returned "NextToken" parameter for subsequent calls
- //
- // See http://goo.gl/ZTEU3G for more details.
- func (as *AutoScaling) DescribeTags(filter *Filter, maxRecords int, nextToken string) (
- resp *DescribeTagsResp, err error) {
- params := makeParams("DescribeTags")
-
- if maxRecords != 0 {
- params["MaxRecords"] = strconv.Itoa(maxRecords)
- }
- if nextToken != "" {
- params["NextToken"] = nextToken
- }
-
- filter.addParams(params)
-
- resp = new(DescribeTagsResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DescribeTerminationPolicyTypes response wrapper
- //
- // See http://goo.gl/ZTEU3G for more details.
- type DescribeTerminationPolicyTypesResp struct {
- TerminationPolicyTypes []string `xml:"DescribeTerminationPolicyTypesResult>TerminationPolicyTypes>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DescribeTerminationPolicyTypes returns a list of all termination policies supported by Auto Scaling
- //
- // See http://goo.gl/ZTEU3G for more details.
- func (as *AutoScaling) DescribeTerminationPolicyTypes() (resp *DescribeTerminationPolicyTypesResp, err error) {
- params := makeParams("DescribeTerminationPolicyTypes")
-
- resp = new(DescribeTerminationPolicyTypesResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DetachInstancesResult wraps a DetachInstances response
- type DetachInstancesResult struct {
- Activities []Activity `xml:"DetachInstancesResult>Activities>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // DetachInstances removes an instance from an Auto Scaling group
- //
- // See http://goo.gl/cNwrqF for more details
- func (as *AutoScaling) DetachInstances(asgName string, instanceIds []string, decrementCapacity bool) (
- resp *DetachInstancesResult, err error) {
- params := makeParams("DetachInstances")
- params["AutoScalingGroupName"] = asgName
- params["ShouldDecrementDesiredCapacity"] = strconv.FormatBool(decrementCapacity)
-
- if len(instanceIds) > 0 {
- addParamsList(params, "InstanceIds.member", instanceIds)
- }
-
- resp = new(DetachInstancesResult)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // DisableMetricsCollection disables monitoring of group metrics for the Auto Scaling group specified in asgName.
- // You can specify the list of affected metrics with the metrics parameter. If no metrics are specified, all metrics are disabled
- //
- // See http://goo.gl/kAvzQw for more details.
- func (as *AutoScaling) DisableMetricsCollection(asgName string, metrics []string) (
- resp *SimpleResp, err error) {
- params := makeParams("DisableMetricsCollection")
- params["AutoScalingGroupName"] = asgName
-
- if len(metrics) > 0 {
- addParamsList(params, "Metrics.member", metrics)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // EnableMetricsCollection enables monitoring of group metrics for the Auto Scaling group specified in asNmae.
- // You can specify the list of affected metrics with the metrics parameter.
- // Auto Scaling metrics collection can be turned on only if the InstanceMonitoring flag is set to true.
- // Currently, the only legal granularity is "1Minute".
- //
- // See http://goo.gl/UcVDWn for more details.
- func (as *AutoScaling) EnableMetricsCollection(asgName string, metrics []string, granularity string) (
- resp *SimpleResp, err error) {
- params := makeParams("EnableMetricsCollection")
- params["AutoScalingGroupName"] = asgName
- params["Granularity"] = granularity
-
- if len(metrics) > 0 {
- addParamsList(params, "Metrics.member", metrics)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // EnterStandbyResult wraps an EnterStandby response
- type EnterStandbyResult struct {
- Activities []Activity `xml:"EnterStandbyResult>Activities>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // EnterStandby moves instances in an Auto Scaling group into a Standby mode.
- //
- // See http://goo.gl/BJ3lXs for more information
- func (as *AutoScaling) EnterStandby(asgName string, instanceIds []string, decrementCapacity bool) (
- resp *EnterStandbyResult, err error) {
- params := makeParams("EnterStandby")
- params["AutoScalingGroupName"] = asgName
- params["ShouldDecrementDesiredCapacity"] = strconv.FormatBool(decrementCapacity)
-
- if len(instanceIds) > 0 {
- addParamsList(params, "InstanceIds.member", instanceIds)
- }
-
- resp = new(EnterStandbyResult)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // ExecutePolicy executes the specified policy.
- //
- // See http://goo.gl/BxHpFc for more details.
- func (as *AutoScaling) ExecutePolicy(policyName string, asgName string, honorCooldown bool) (
- resp *SimpleResp, err error) {
- params := makeParams("ExecutePolicy")
- params["PolicyName"] = policyName
-
- if asgName != "" {
- params["AutoScalingGroupName"] = asgName
- }
- if honorCooldown {
- params["HonorCooldown"] = strconv.FormatBool(honorCooldown)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // ExitStandbyResult wraps an ExitStandby response
- type ExitStandbyResult struct {
- Activities []Activity `xml:"ExitStandbyResult>Activities>member"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // ExitStandby moves an instance out of Standby mode.
- //
- // See http://goo.gl/9zQV4G for more information
- func (as *AutoScaling) ExitStandby(asgName string, instanceIds []string) (
- resp *ExitStandbyResult, err error) {
- params := makeParams("ExitStandby")
- params["AutoScalingGroupName"] = asgName
-
- if len(instanceIds) > 0 {
- addParamsList(params, "InstanceIds.member", instanceIds)
- }
-
- resp = new(ExitStandbyResult)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // PutLifecycleHookParams wraps a PutLifecycleHook request
- //
- // See http://goo.gl/zsNqp5 for more details
- type PutLifecycleHookParams struct {
- AutoScalingGroupName string
- DefaultResult string
- HeartbeatTimeout int
- LifecycleHookName string
- LifecycleTransition string
- NotificationMetadata string
- NotificationTargetARN string
- RoleARN string
- }
-
- // PutLifecycleHook Creates or updates a lifecycle hook for an Auto Scaling Group.
- //
- // Part of the basic sequence for adding a lifecycle hook to an Auto Scaling group:
- // 1) Create a notification target (SQS queue || SNS Topic)
- // 2) Create an IAM role to allow the ASG topublish lifecycle notifications to the designated SQS queue or SNS topic
- // 3) *** Create the lifecycle hook. You can create a hook that acts when instances launch or when instances terminate***
- // 4) If necessary, record the lifecycle action heartbeat to keep the instance in a pending state
- // 5) Complete the lifecycle action
- //
- // See http://goo.gl/9XrROq for more details.
- func (as *AutoScaling) PutLifecycleHook(options *PutLifecycleHookParams) (
- resp *SimpleResp, err error) {
- params := makeParams("PutLifecycleHook")
- params["AutoScalingGroupName"] = options.AutoScalingGroupName
- params["LifecycleHookName"] = options.LifecycleHookName
-
- if options.DefaultResult != "" {
- params["DefaultResult"] = options.DefaultResult
- }
- if options.HeartbeatTimeout != 0 {
- params["HeartbeatTimeout"] = strconv.Itoa(options.HeartbeatTimeout)
- }
- if options.LifecycleTransition != "" {
- params["LifecycleTransition"] = options.LifecycleTransition
- }
- if options.NotificationMetadata != "" {
- params["NotificationMetadata"] = options.NotificationMetadata
- }
- if options.NotificationTargetARN != "" {
- params["NotificationTargetARN"] = options.NotificationTargetARN
- }
- if options.RoleARN != "" {
- params["RoleARN"] = options.RoleARN
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // PutNotificationConfiguration configures an Auto Scaling group to send notifications when specified events take place.
- //
- // See http://goo.gl/9XrROq for more details.
- func (as *AutoScaling) PutNotificationConfiguration(asgName string, notificationTypes []string, topicARN string) (
- resp *SimpleResp, err error) {
- params := makeParams("PutNotificationConfiguration")
- params["AutoScalingGroupName"] = asgName
- params["TopicARN"] = topicARN
-
- if len(notificationTypes) > 0 {
- addParamsList(params, "NotificationTypes.member", notificationTypes)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // PutScalingPolicyParams wraps a PutScalingPolicyParams request
- //
- // See http://goo.gl/o0E8hl for more details.
- type PutScalingPolicyParams struct {
- AutoScalingGroupName string
- PolicyName string
- ScalingAdjustment int
- AdjustmentType string
- Cooldown int
- MinAdjustmentStep int
- }
-
- // PutScalingPolicy response wrapper
- //
- // See http://goo.gl/o0E8hl for more details.
- type PutScalingPolicyResp struct {
- PolicyARN string `xml:"PutScalingPolicyResult>PolicyARN"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // PutScalingPolicy creates or updates a policy for an Auto Scaling group
- //
- // See http://goo.gl/o0E8hl for more details.
- func (as *AutoScaling) PutScalingPolicy(options *PutScalingPolicyParams) (
- resp *PutScalingPolicyResp, err error) {
- params := makeParams("PutScalingPolicy")
- params["AutoScalingGroupName"] = options.AutoScalingGroupName
- params["PolicyName"] = options.PolicyName
- params["ScalingAdjustment"] = strconv.Itoa(options.ScalingAdjustment)
- params["AdjustmentType"] = options.AdjustmentType
-
- if options.Cooldown != 0 {
- params["Cooldown"] = strconv.Itoa(options.Cooldown)
- }
- if options.MinAdjustmentStep != 0 {
- params["MinAdjustmentStep"] = strconv.Itoa(options.MinAdjustmentStep)
- }
-
- resp = new(PutScalingPolicyResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // PutScheduledUpdateGroupActionParams contains the details of the ScheduledAction to be added.
- //
- // See http://goo.gl/sLPi0d for more details
- type PutScheduledUpdateGroupActionParams struct {
- AutoScalingGroupName string
- DesiredCapacity int
- EndTime time.Time
- MaxSize int
- MinSize int
- Recurrence string
- ScheduledActionName string
- StartTime time.Time
- }
-
- // PutScheduledUpdateGroupAction creates or updates a scheduled scaling action for an
- // AutoScaling group. Scheduled actions can be made up to thirty days in advance. When updating
- // a scheduled scaling action, if you leave a parameter unspecified, the corresponding value
- // remains unchanged in the affected AutoScaling group.
- //
- // Auto Scaling supports the date and time expressed in "YYYY-MM-DDThh:mm:ssZ" format in UTC/GMT
- // only.
- //
- // See http://goo.gl/sLPi0d for more details.
- func (as *AutoScaling) PutScheduledUpdateGroupAction(options *PutScheduledUpdateGroupActionParams) (
- resp *SimpleResp, err error) {
- params := makeParams("PutScheduledUpdateGroupAction")
- params["AutoScalingGroupName"] = options.AutoScalingGroupName
- params["ScheduledActionName"] = options.ScheduledActionName
- params["MinSize"] = strconv.Itoa(options.MinSize)
- params["MaxSize"] = strconv.Itoa(options.MaxSize)
- params["DesiredCapacity"] = strconv.Itoa(options.DesiredCapacity)
-
- if !options.StartTime.IsZero() {
- params["StartTime"] = options.StartTime.Format(time.RFC3339)
- }
- if !options.EndTime.IsZero() {
- params["EndTime"] = options.EndTime.Format(time.RFC3339)
- }
- if options.Recurrence != "" {
- params["Recurrence"] = options.Recurrence
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // RecordLifecycleActionHeartbeat ecords a heartbeat for the lifecycle action associated with a specific token.
- // This extends the timeout by the length of time defined by the HeartbeatTimeout parameter of the
- // PutLifecycleHook operation.
- //
- // Part of the basic sequence for adding a lifecycle hook to an Auto Scaling group:
- // 1) Create a notification target (SQS queue || SNS Topic)
- // 2) Create an IAM role to allow the ASG topublish lifecycle notifications to the designated SQS queue or SNS topic
- // 3) Create the lifecycle hook. You can create a hook that acts when instances launch or when instances terminate
- // 4) ***If necessary, record the lifecycle action heartbeat to keep the instance in a pending state***
- // 5) Complete the lifecycle action
- //
- // See http://goo.gl/jc70xp for more details.
- func (as *AutoScaling) RecordLifecycleActionHeartbeat(asgName, lifecycleActionToken, hookName string) (
- resp *SimpleResp, err error) {
- params := makeParams("RecordLifecycleActionHeartbeat")
- params["AutoScalingGroupName"] = asgName
- params["LifecycleActionToken"] = lifecycleActionToken
- params["LifecycleHookName"] = hookName
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // ResumeProcesses resumes the scaling processes for the scaling group. If no processes are
- // provided, all processes are resumed.
- //
- // See http://goo.gl/XWIIg1 for more details.
- func (as *AutoScaling) ResumeProcesses(asgName string, processes []string) (
- resp *SimpleResp, err error) {
- params := makeParams("ResumeProcesses")
- params["AutoScalingGroupName"] = asgName
-
- if len(processes) > 0 {
- addParamsList(params, "ScalingProcesses.member", processes)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // SetDesiredCapacity changes the DesiredCapacity of an AutoScaling group.
- //
- // See http://goo.gl/3WGZbI for more details.
- func (as *AutoScaling) SetDesiredCapacity(asgName string, desiredCapacity int, honorCooldown bool) (
- resp *SimpleResp, err error) {
- params := makeParams("SetDesiredCapacity")
- params["AutoScalingGroupName"] = asgName
- params["DesiredCapacity"] = strconv.Itoa(desiredCapacity)
- params["HonorCooldown"] = strconv.FormatBool(honorCooldown)
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // SetInstanceHealth sets the health status of a specified instance that belongs to any of your Auto Scaling groups.
- //
- // See http://goo.gl/j4ZRxh for more details.
- func (as *AutoScaling) SetInstanceHealth(id string, healthStatus string, respectGracePeriod bool) (
- resp *SimpleResp, err error) {
- params := makeParams("SetInstanceHealth")
- params["HealthStatus"] = healthStatus
- params["InstanceId"] = id
- // Default is true
- params["ShouldRespectGracePeriod"] = strconv.FormatBool(respectGracePeriod)
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // SuspendProcesses suspends the processes for the autoscaling group. If no processes are
- // provided, all processes are suspended.
- //
- // If you suspend either of the two primary processes (Launch or Terminate), this can prevent other
- // process types from functioning properly.
- //
- // See http://goo.gl/DUJpQy for more details.
- func (as *AutoScaling) SuspendProcesses(asgName string, processes []string) (
- resp *SimpleResp, err error) {
- params := makeParams("SuspendProcesses")
- params["AutoScalingGroupName"] = asgName
-
- if len(processes) > 0 {
- addParamsList(params, "ScalingProcesses.member", processes)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // TerminateInstanceInAutoScalingGroupResp response wrapper
- //
- // See http://goo.gl/ki5hMh for more details.
- type TerminateInstanceInAutoScalingGroupResp struct {
- Activity Activity `xml:"TerminateInstanceInAutoScalingGroupResult>Activity"`
- RequestId string `xml:"ResponseMetadata>RequestId"`
- }
-
- // TerminateInstanceInAutoScalingGroup terminates the specified instance.
- // Optionally, the desired group size can be adjusted by setting decrCap to true
- //
- // See http://goo.gl/ki5hMh for more details.
- func (as *AutoScaling) TerminateInstanceInAutoScalingGroup(id string, decrCap bool) (
- resp *TerminateInstanceInAutoScalingGroupResp, err error) {
- params := makeParams("TerminateInstanceInAutoScalingGroup")
- params["InstanceId"] = id
- params["ShouldDecrementDesiredCapacity"] = strconv.FormatBool(decrCap)
-
- resp = new(TerminateInstanceInAutoScalingGroupResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
-
- // UpdateAutoScalingGroup updates the scaling group.
- //
- // To update an auto scaling group with a launch configuration that has the InstanceMonitoring
- // flag set to False, you must first ensure that collection of group metrics is disabled.
- // Otherwise calls to UpdateAutoScalingGroup will fail.
- //
- // See http://goo.gl/rqrmxy for more details.
- func (as *AutoScaling) UpdateAutoScalingGroup(asg *AutoScalingGroup) (resp *SimpleResp, err error) {
- params := makeParams("UpdateAutoScalingGroup")
-
- params["AutoScalingGroupName"] = asg.AutoScalingGroupName
- params["MaxSize"] = strconv.Itoa(asg.MaxSize)
- params["MinSize"] = strconv.Itoa(asg.MinSize)
- params["DesiredCapacity"] = strconv.Itoa(asg.DesiredCapacity)
-
- if asg.DefaultCooldown > 0 {
- params["DefaultCooldown"] = strconv.Itoa(asg.DefaultCooldown)
- }
- if asg.HealthCheckGracePeriod > 0 {
- params["HealthCheckGracePeriod"] = strconv.Itoa(asg.HealthCheckGracePeriod)
- }
- if asg.HealthCheckType != "" {
- params["HealthCheckType"] = asg.HealthCheckType
- }
- if asg.LaunchConfigurationName != "" {
- params["LaunchConfigurationName"] = asg.LaunchConfigurationName
- }
- if asg.PlacementGroup != "" {
- params["PlacementGroup"] = asg.PlacementGroup
- }
- if asg.VPCZoneIdentifier != "" {
- params["VPCZoneIdentifier"] = asg.VPCZoneIdentifier
- }
-
- if len(asg.AvailabilityZones) > 0 {
- addParamsList(params, "AvailabilityZones.member", asg.AvailabilityZones)
- }
- if len(asg.TerminationPolicies) > 0 {
- addParamsList(params, "TerminationPolicies.member", asg.TerminationPolicies)
- }
-
- resp = new(SimpleResp)
- if err := as.query(params, resp); err != nil {
- return nil, err
- }
- return resp, nil
- }
|