Class: RightAws::AsInterface
- Inherits:
-
RightAwsBase
- Object
- RightAwsBase
- RightAws::AsInterface
- Includes:
- RightAwsBaseInterface
- Defined in:
- lib/as/right_as_interface.rb
Overview
RightAWS::AsInterface – RightScale Amazon Auto Scaling interface
The RightAws::AsInterface class provides a complete interface to Amazon Auto Scaling service.
For explanations of the semantics of each call, please refer to Amazon’s documentation at docs.amazonwebservices.com/AutoScaling/latest/DeveloperGuide/
Create an interface handle:
as = RightAws::AsInterface.new(aws_access_key_id, aws_security_access_key)
Create a launch configuration:
as.create_launch_configuration('CentOS.5.1-c', 'ami-08f41161', 'm1.small',
:key_name => 'kd-moo-test',
:security_groups => ['default'],
:user_data => "Woohoo: CentOS.5.1-c" )
Create an AutoScaling group:
as.create_auto_scaling_group('CentOS.5.1-c-array', 'CentOS.5.1-c', 'us-east-1c',
:min_size => 2,
:max_size => 5)
Create a new trigger:
as.create_or_update_scaling_trigger('kd.tr.1', 'CentOS.5.1-c-array',
:measure_name => 'CPUUtilization',
:statistic => :average,
:dimensions => {
'AutoScalingGroupName' => 'CentOS.5.1-c-array',
'Namespace' => 'AWS',
'Service' => 'EC2' },
:period => 60,
:lower_threshold => 5,
:lower_breach_scale_increment => -1,
:upper_threshold => 60,
:upper_breach_scale_increment => 1,
:breach_duration => 300 )
Describe scaling activity:
as.incrementally_describe_scaling_activities('CentOS.5.1-c-array') #=> List of activities
Describe the Auto Scaling group status:
as.describe_auto_scaling_groups('CentOS.5.1-c-array') #=> Current group status
Defined Under Namespace
Classes: DescribeAutoScalingGroupsParser, DescribeLaunchConfigurationsParser, DescribeScalingActivitiesParser, DescribeTriggersParser
Constant Summary collapse
- API_VERSION =
Amazon AS API version being used
'2009-05-15'
- DEFAULT_HOST =
'autoscaling.amazonaws.com'
- DEFAULT_PATH =
'/'
- DEFAULT_PROTOCOL =
'https'
- DEFAULT_PORT =
443
- @@bench =
AwsBenchmarkingBlock.new
Constants included from RightAwsBaseInterface
RightAwsBaseInterface::BLOCK_DEVICE_KEY_MAPPING, RightAwsBaseInterface::DEFAULT_SIGNATURE_VERSION
Constants inherited from RightAwsBase
RightAwsBase::AMAZON_PROBLEMS, RightAwsBase::RAISE_ON_TIMEOUT_ON_ACTIONS
Instance Attribute Summary
Attributes included from RightAwsBaseInterface
#aws_access_key_id, #aws_secret_access_key, #cache, #connection, #last_errors, #last_request, #last_request_id, #last_response, #logger, #params, #signature_version
Class Method Summary collapse
Instance Method Summary collapse
-
#create_auto_scaling_group(auto_scaling_group_name, launch_configuration_name, availability_zones, options = {}) ⇒ Object
Creates a new auto scaling group with the specified name.
-
#create_launch_configuration(launch_configuration_name, image_id, instance_type, options = {}) ⇒ Object
Creates a new Launch Configuration.
-
#create_or_update_scaling_trigger(trigger_name, auto_scaling_group_name, options = {}) ⇒ Object
Create or update specified trigger.
-
#delete_auto_scaling_group(auto_scaling_group_name) ⇒ Object
Deletes all configuration for this auto scaling group and also deletes the group.
-
#delete_launch_configuration(launch_configuration_name) ⇒ Object
Delete launch configuration.
-
#delete_trigger(trigger_name, auto_scaling_group_name) ⇒ Object
Delete specified trigger.
-
#describe_auto_scaling_groups(*auto_scaling_group_names) ⇒ Object
Describe auto scaling groups.
-
#describe_launch_configurations(*launch_configuration_names) ⇒ Object
Describe all Launch Configurations.
-
#describe_scaling_activities(auto_scaling_group_name, *activity_ids) ⇒ Object
Describe all Scaling Activities.
-
#describe_triggers(auto_scaling_group_name) ⇒ Object
Describe triggers.
-
#generate_request(action, params = {}) ⇒ Object
:nodoc:.
-
#incrementally_describe_launch_configurations(*launch_configuration_names, &block) ⇒ Object
Incrementally describe Launch Configurations.
-
#incrementally_describe_scaling_activities(auto_scaling_group_name, *activity_ids, &block) ⇒ Object
Incrementally describe Scaling Activities.
-
#initialize(aws_access_key_id = nil, aws_secret_access_key = nil, params = {}) ⇒ AsInterface
constructor
Create a new handle to an CSLS account.
-
#request_info(request, parser) ⇒ Object
Sends request to Amazon and parses the response Raises AwsError if any banana happened.
-
#set_desired_capacity(auto_scaling_group_name, desired_capacity) ⇒ Object
Adjusts the desired size of the Capacity Group by using scaling actions, as necessary.
-
#terminate_instance_in_auto_scaling_group(instance_id, should_decrement_desired_capacity = true) ⇒ Object
This call will terminate the specified Instance.
-
#update_auto_scaling_group(auto_scaling_group_name, options = {}) ⇒ Object
Updates the configuration for the given AutoScalingGroup.
Methods included from RightAwsBaseInterface
#amazonize_block_device_mappings, #amazonize_hash_with_key_mapping, #amazonize_list, #amazonize_list_with_key_mapping, #cache_hits?, caching, caching=, #caching?, #destroy_connection, #generate_request_impl, #get_connection, #get_connections_storage, #get_server_url, #incrementally_list_items, #init, #map_api_keys_and_values, #on_exception, #request_cache_or_info, #request_info_impl, #signed_service_params, #update_cache, #with_connection_options
Methods inherited from RightAwsBase
amazon_problems, amazon_problems=, raise_on_timeout_on_actions, raise_on_timeout_on_actions=
Constructor Details
#initialize(aws_access_key_id = nil, aws_secret_access_key = nil, params = {}) ⇒ AsInterface
Create a new handle to an CSLS account. All handles share the same per process or per thread HTTP connection to Amazon CSLS. Each handle is for a specific account. The params have the following options:
-
:endpoint_url
a fully qualified url to Amazon API endpoint (this overwrites: :server, :port, :service, :protocol). Example: ‘autoscaling.amazonaws.com/’ -
:server
: AS service host, default: DEFAULT_HOST -
:port
: AS service port, default: DEFAULT_PORT -
:protocol
: ‘http’ or ‘https’, default: DEFAULT_PROTOCOL -
:logger
: for log messages, default: RAILS_DEFAULT_LOGGER else STDOUT -
:signature_version
: The signature version : ‘0’,‘1’ or ‘2’(default) -
:cache
: true/false(default): describe_auto_scaling_groups
102 103 104 105 106 107 108 109 110 111 112 |
# File 'lib/as/right_as_interface.rb', line 102 def initialize(aws_access_key_id=nil, aws_secret_access_key=nil, params={}) init({ :name => 'AS', :default_host => ENV['AS_URL'] ? URI.parse(ENV['AS_URL']).host : DEFAULT_HOST, :default_port => ENV['AS_URL'] ? URI.parse(ENV['AS_URL']).port : DEFAULT_PORT, :default_service => ENV['AS_URL'] ? URI.parse(ENV['AS_URL']).path : DEFAULT_PATH, :default_protocol => ENV['AS_URL'] ? URI.parse(ENV['AS_URL']).scheme : DEFAULT_PROTOCOL, :default_api_version => ENV['AS_API_VERSION'] || API_VERSION }, aws_access_key_id || ENV['AWS_ACCESS_KEY_ID'] , aws_secret_access_key|| ENV['AWS_SECRET_ACCESS_KEY'], params) end |
Class Method Details
.bench_service ⇒ Object
87 88 89 |
# File 'lib/as/right_as_interface.rb', line 87 def self.bench_service @@bench.service end |
.bench_xml ⇒ Object
84 85 86 |
# File 'lib/as/right_as_interface.rb', line 84 def self.bench_xml @@bench.xml end |
Instance Method Details
#create_auto_scaling_group(auto_scaling_group_name, launch_configuration_name, availability_zones, options = {}) ⇒ Object
Creates a new auto scaling group with the specified name. Returns true
or raises an exception.
Options: :min_size
, :max_size
, :cooldown
, :load_balancer_names
as.create_auto_scaling_group('CentOS.5.1-c-array', 'CentOS.5.1-c', 'us-east-1c',
:min_size => 2,
:max_size => 5) #=> true
Amazon’s notice: Constraints: Restricted to one Availability Zone
151 152 153 154 155 156 157 158 159 160 161 162 163 164 |
# File 'lib/as/right_as_interface.rb', line 151 def create_auto_scaling_group(auto_scaling_group_name, launch_configuration_name, availability_zones, ={}) [:min_size] ||= 1 [:max_size] ||= 20 [:cooldown] ||= 0 request_hash = amazonize_list('AvailabilityZones.member', availability_zones) request_hash.merge!( amazonize_list('LoadBalancerNames.member', [:load_balancer_names]) ) request_hash.merge!( 'AutoScalingGroupName' => auto_scaling_group_name, 'LaunchConfigurationName' => launch_configuration_name, 'MinSize' => [:min_size], 'MaxSize' => [:max_size], 'Cooldown' => [:cooldown] ) link = generate_request("CreateAutoScalingGroup", request_hash) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |
#create_launch_configuration(launch_configuration_name, image_id, instance_type, options = {}) ⇒ Object
Creates a new Launch Configuration. Please note that the launch configuration name used must be unique, within the scope of your Amazon Web Services AWS account, and the maximum limit of launch configurations must not yet have been met, or else the call will fail.
Once created, the new launch configuration is available for immediate use.
Options: :security_groups
, :block_device_mappings
, :key_name
, :user_data
, :kernel_id
, :ramdisk_id
as.create_launch_configuration('kd: CentOS.5.1-c.1', 'ami-08f41161', 'c1.medium',
:key_name => 'tim',
:security_groups => ['default'],
:user_data => "Woohoo: CentOS.5.1-c",
:block_device_mappings => [ { :device_name => '/dev/sdk',
:ebs_snapshot_id => 'snap-145cbc7d',
:ebs_delete_on_termination => true,
:ebs_volume_size => 3,
:virtual_name => 'ephemeral2'
} ]
) #=> true
353 354 355 356 357 358 359 360 361 362 363 364 365 |
# File 'lib/as/right_as_interface.rb', line 353 def create_launch_configuration(launch_configuration_name, image_id, instance_type, ={}) request_hash = { 'LaunchConfigurationName' => launch_configuration_name, 'ImageId' => image_id, 'InstanceType' => instance_type } request_hash.merge!(amazonize_list('SecurityGroups.member', [:security_groups])) unless [:security_groups].right_blank? request_hash.merge!(amazonize_block_device_mappings([:block_device_mappings], 'BlockDeviceMappings.member')) request_hash['KeyName'] = [:key_name] if [:key_name] request_hash['UserData'] = Base64.encode64([:user_data]).delete("\n") unless [:user_data].right_blank? if [:user_data] request_hash['KernelId'] = [:kernel_id] if [:kernel_id] request_hash['RamdiskId'] = [:ramdisk_id] if [:ramdisk_id] link = generate_request("CreateLaunchConfiguration", request_hash) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |
#create_or_update_scaling_trigger(trigger_name, auto_scaling_group_name, options = {}) ⇒ Object
Create or update specified trigger. This call sets the parameters that governs when and how to scale an AutoScalingGroup. If the Trigger, within the scope of the caller’s AWS account, specified already exists, it will be updated. If a trigger with a different name already exists, this call will fail.
Returns true
or an exception.
Options: :measure_name
, :statistic
, :period
, :lower_threshold
, :lower_breach_scale_increment
, :upper_threshold
, :upper_breach_scale_increment
, :dimensions
, :breach_duration
, :unit
, :custom_unit
as.create_or_update_scaling_trigger('kd.tr.1', 'CentOS.5.1-c-array',
:measure_name => 'CPUUtilization',
:statistic => :average,
:dimensions => {
'AutoScalingGroupName' => 'CentOS.5.1-c-array',
'Namespace' => 'AWS',
'Service' => 'EC2' },
:period => 60,
:lower_threshold => 5,
:lower_breach_scale_increment => -1,
:upper_threshold => 60,
:upper_breach_scale_increment => 1,
:breach_duration => 300 ) #=> true
473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 |
# File 'lib/as/right_as_interface.rb', line 473 def create_or_update_scaling_trigger(trigger_name, auto_scaling_group_name, ={}) request_hash = { 'TriggerName' => trigger_name, 'AutoScalingGroupName' => auto_scaling_group_name, 'MeasureName' => [:measure_name], 'Statistic' => [:statistic].to_s.capitalize, 'Period' => [:period], 'LowerThreshold' => [:lower_threshold], 'LowerBreachScaleIncrement' => [:lower_breach_scale_increment], 'UpperThreshold' => [:upper_threshold], 'UpperBreachScaleIncrement' => [:upper_breach_scale_increment], 'BreachDuration' => [:breach_duration] } request_hash['Unit'] = [:unit] if [:unit] request_hash['CustomUnit'] = [:custom_unit] if [:custom_unit] dimensions = [] ([:dimensions] || {}).each do |key, values| Array(values).each { |value| dimensions << [key, value] } end request_hash.merge!(amazonize_list(['Dimensions.member.?.Name', 'Dimensions.member.?.Value'], dimensions)) link = generate_request("CreateOrUpdateScalingTrigger", request_hash) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |
#delete_auto_scaling_group(auto_scaling_group_name) ⇒ Object
Deletes all configuration for this auto scaling group and also deletes the group. Returns true
or raises an exception.
169 170 171 172 |
# File 'lib/as/right_as_interface.rb', line 169 def delete_auto_scaling_group(auto_scaling_group_name) link = generate_request('DeleteAutoScalingGroup', 'AutoScalingGroupName' => auto_scaling_group_name) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |
#delete_launch_configuration(launch_configuration_name) ⇒ Object
Delete launch configuration. Returns true
or an exception.
as.delete_launch_configuration('CentOS.5.1') #=> true
440 441 442 443 |
# File 'lib/as/right_as_interface.rb', line 440 def delete_launch_configuration(launch_configuration_name) link = generate_request('DeleteLaunchConfiguration', 'LaunchConfigurationName' => launch_configuration_name) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |
#delete_trigger(trigger_name, auto_scaling_group_name) ⇒ Object
Delete specified trigger. Returns true
or an exception.
as.delete_trigger('kd.tr.1', 'CentOS.5.1-c-array') #=> true
526 527 528 529 530 |
# File 'lib/as/right_as_interface.rb', line 526 def delete_trigger(trigger_name, auto_scaling_group_name) link = generate_request('DeleteTrigger', 'TriggerName' => trigger_name, 'AutoScalingGroupName' => auto_scaling_group_name) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |
#describe_auto_scaling_groups(*auto_scaling_group_names) ⇒ Object
Describe auto scaling groups. Returns a full description of the AutoScalingGroups from the given list. This includes all EC2 instances that are members of the group. If a list of names is not provided, then the full details of all AutoScalingGroups is returned. This style conforms to the EC2 DescribeInstances API behavior.
134 135 136 137 138 139 |
# File 'lib/as/right_as_interface.rb', line 134 def describe_auto_scaling_groups(*auto_scaling_group_names) auto_scaling_group_names = auto_scaling_group_names.flatten.compact request_hash = amazonize_list('AutoScalingGroupNames.member', auto_scaling_group_names) link = generate_request("DescribeAutoScalingGroups", request_hash) request_cache_or_info(:describe_auto_scaling_groups, link, DescribeAutoScalingGroupsParser, @@bench, auto_scaling_group_names.right_blank?) end |
#describe_launch_configurations(*launch_configuration_names) ⇒ Object
Describe all Launch Configurations. Returns an array of configurations.
as.describe_launch_configurations #=>
[{:security_groups=>["default"],
:ramdisk_id=>"",
:user_data=>"V29vaG9vOiBDZW50T1MuNS4xLWM=",
:instance_type=>"c1.medium",
:block_device_mappings=>
[{:virtual_name=>"ephemeral2", :device_name=>"/dev/sdk"}],
:launch_configuration_name=>"kd: CentOS.5.1-c.1",
:created_time=>"2010-03-29T10:00:32.742Z",
:image_id=>"ami-08f41161",
:key_name=>"tim",
:kernel_id=>""}, ...]
384 385 386 387 388 389 390 391 |
# File 'lib/as/right_as_interface.rb', line 384 def describe_launch_configurations(*launch_configuration_names) result = [] incrementally_describe_launch_configurations(*launch_configuration_names) do |response| result += response[:launch_configurations] true end result end |
#describe_scaling_activities(auto_scaling_group_name, *activity_ids) ⇒ Object
Describe all Scaling Activities.
describe_scaling_activities('CentOS.5.1-c-array') #=>
[{:cause=>
"At 2009-05-28 10:11:35Z trigger kd.tr.1 breached high threshold value for
CPUUtilization, 10.0, adjusting the desired capacity from 1 to 2. At 2009-05-28 10:11:35Z
a breaching trigger explicitly set group desired capacity changing the desired capacity
from 1 to 2. At 2009-05-28 10:11:40Z an instance was started in response to a difference
between desired and actual capacity, increasing the capacity from 1 to 2.",
:activity_id=>"067c9abb-f8a7-4cf8-8f3c-dc6f280457c4",
:progress=>0,
:description=>"Launching a new EC2 instance",
:status_code=>"InProgress",
:start_time=>Thu May 28 10:11:40 UTC 2009},
{:end_time=>Thu May 28 09:35:23 UTC 2009,
:cause=>
"At 2009-05-28 09:31:21Z a user request created an AutoScalingGroup changing the desired
capacity from 0 to 1. At 2009-05-28 09:32:35Z an instance was started in response to a
difference between desired and actual capacity, increasing the capacity from 0 to 1.",
:activity_id=>"90d506ba-1b75-4d29-8739-0a75b1ba8030",
:progress=>100,
:description=>"Launching a new EC2 instance",
:status_code=>"Successful",
:start_time=>Thu May 28 09:32:35 UTC 2009}]}
245 246 247 248 249 250 251 252 |
# File 'lib/as/right_as_interface.rb', line 245 def describe_scaling_activities(auto_scaling_group_name, *activity_ids) result = [] incrementally_describe_scaling_activities(auto_scaling_group_name, *activity_ids) do |response| result += response[:scaling_activities] true end result end |
#describe_triggers(auto_scaling_group_name) ⇒ Object
Describe triggers. Returns a full description of the trigger in the specified Auto Scaling Group.
as.describe_triggers('CentOS.5.1-c-array') #=>
[{:status=>"HighBreaching",
:breach_duration=>300,
:measure_name=>"CPUUtilization",
:trigger_name=>"kd.tr.1",
:period=>60,
:lower_threshold=>0.0,
:lower_breach_scale_increment=>-1,
:dimensions=>
{"Namespace"=>"AWS",
"AutoScalingGroupName"=>"CentOS.5.1-c-array",
"Service"=>"EC2"},
:statistic=>"Average",
:upper_threshold=>10.0,
:created_time=>Thu May 28 09:48:46 UTC 2009,
:auto_scaling_group_name=>"CentOS.5.1-c-array",
:upper_breach_scale_increment=>1}]
516 517 518 519 |
# File 'lib/as/right_as_interface.rb', line 516 def describe_triggers(auto_scaling_group_name) link = generate_request("DescribeTriggers", 'AutoScalingGroupName' => auto_scaling_group_name) request_info(link, DescribeTriggersParser.new(:logger => @logger)) end |
#generate_request(action, params = {}) ⇒ Object
:nodoc:
114 115 116 |
# File 'lib/as/right_as_interface.rb', line 114 def generate_request(action, params={}) #:nodoc: generate_request_impl(:get, action, params ) end |
#incrementally_describe_launch_configurations(*launch_configuration_names, &block) ⇒ Object
Incrementally describe Launch Configurations. Returns a full description of the launch configurations given the specified names. If no names are specified, then the full details of all launch configurations are returned.
Optional params: :max_records
, :next_token
.
# get max 100 first configurations
as.incrementally_describe_launch_configurations #=>
{:launch_configurations=>
[{:created_time=>Thu May 28 09:31:20 UTC 2009,
:kernel_id=>"",
:launch_configuration_name=>"CentOS.5.1-c",
:ramdisk_id=>"",
:security_groups=>["default"],
:key_name=>"kd-moo-test",
:user_data=>"Woohoo: CentOS.5.1-c-array",
:image_id=>"ami-08f41161",
:block_device_mappings=>[],
:instance_type=>"m1.small"}, ... ]}
# list by 5 records
incrementally_describe_launch_configurations(:max_records => 5) do |response|
puts response.inspect
true
end
419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 |
# File 'lib/as/right_as_interface.rb', line 419 def incrementally_describe_launch_configurations(*launch_configuration_names, &block) launch_configuration_names = launch_configuration_names.flatten.compact params = launch_configuration_names.last.kind_of?(Hash) ? launch_configuration_names.pop : {} request_hash = amazonize_list('LaunchConfigurationNames.member', launch_configuration_names) request_hash['MaxRecords'] = params[:max_records] if params[:max_records] request_hash['NextToken'] = params[:next_token] if params[:next_token] last_response = nil loop do link = generate_request("DescribeLaunchConfigurations", request_hash) last_response = request_info( link, DescribeLaunchConfigurationsParser.new(:logger => @logger) ) request_hash['NextToken'] = last_response[:next_token] break unless block && block.call(last_response) && !last_response[:next_token].right_blank? end last_response end |
#incrementally_describe_scaling_activities(auto_scaling_group_name, *activity_ids, &block) ⇒ Object
Incrementally describe Scaling Activities. Returns the scaling activities specified for the given group. If the input list is empty, all the activities from the past six weeks will be returned. Activities will be sorted by completion time. Activities that have no completion time will be considered as using the most recent possible time.
Optional params: :max_records
, :next_token
.
# get max 100 first activities
as.incrementally_describe_scaling_activities('CentOS.5.1-c-array') #=>
{:scaling_activities=>
[{:cause=>
"At 2009-05-28 10:11:35Z trigger kd.tr.1 breached high threshold value for
CPUUtilization, 10.0, adjusting the desired capacity from 1 to 2. At 2009-05-28 10:11:35Z
a breaching trigger explicitly set group desired capacity changing the desired capacity
from 1 to 2. At 2009-05-28 10:11:40Z an instance was started in response to a difference
between desired and actual capacity, increasing the capacity from 1 to 2.",
:activity_id=>"067c9abb-f8a7-4cf8-8f3c-dc6f280457c4",
:progress=>0,
:description=>"Launching a new EC2 instance",
:status_code=>"InProgress",
:start_time=>Thu May 28 10:11:40 UTC 2009},
{:end_time=>Thu May 28 09:35:23 UTC 2009,
:cause=>
"At 2009-05-28 09:31:21Z a user request created an AutoScalingGroup changing the desired
capacity from 0 to 1. At 2009-05-28 09:32:35Z an instance was started in response to a
difference between desired and actual capacity, increasing the capacity from 0 to 1.",
:activity_id=>"90d506ba-1b75-4d29-8739-0a75b1ba8030",
:progress=>100,
:description=>"Launching a new EC2 instance",
:status_code=>"Successful",
:start_time=>Thu May 28 09:32:35 UTC 2009}]}
# list by 5 records
incrementally_describe_scaling_activities('CentOS.5.1-c-array', :max_records => 5) do |response|
puts response.inspect
true
end
292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 |
# File 'lib/as/right_as_interface.rb', line 292 def incrementally_describe_scaling_activities(auto_scaling_group_name, *activity_ids, &block) activity_ids = activity_ids.flatten.compact params = activity_ids.last.kind_of?(Hash) ? activity_ids.pop : {} request_hash = amazonize_list('ActivityIds.member', activity_ids) request_hash['AutoScalingGroupName'] = auto_scaling_group_name request_hash['MaxRecords'] = params[:max_records] if params[:max_records] request_hash['NextToken'] = params[:next_token] if params[:next_token] last_response = nil loop do link = generate_request("DescribeScalingActivities", request_hash) last_response = request_info( link, DescribeScalingActivitiesParser.new(:logger => @logger)) request_hash['NextToken'] = last_response[:next_token] break unless block && block.call(last_response) && !last_response[:next_token].right_blank? end last_response end |
#request_info(request, parser) ⇒ Object
Sends request to Amazon and parses the response Raises AwsError if any banana happened
120 121 122 |
# File 'lib/as/right_as_interface.rb', line 120 def request_info(request, parser) #:nodoc: request_info_impl(:aass_connection, @@bench, request, parser) end |
#set_desired_capacity(auto_scaling_group_name, desired_capacity) ⇒ Object
Adjusts the desired size of the Capacity Group by using scaling actions, as necessary. When adjusting the size of the group downward, it is not possible to define which EC2 instances will be terminated. This also applies to any auto-scaling decisions that might result in the termination of instances.
Returns true
or raises an exception.
as.set_desired_capacity('CentOS.5.1-c',3) #=> 3
183 184 185 186 187 |
# File 'lib/as/right_as_interface.rb', line 183 def set_desired_capacity(auto_scaling_group_name, desired_capacity) link = generate_request('SetDesiredCapacity', 'AutoScalingGroupName' => auto_scaling_group_name, 'DesiredCapacity' => desired_capacity ) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |
#terminate_instance_in_auto_scaling_group(instance_id, should_decrement_desired_capacity = true) ⇒ Object
This call will terminate the specified Instance. Optionally, the desired group size can be adjusted. If set to true, the default, the AutoScalingGroup size will decrease by one. If the AutoScalingGroup is associated with a LoadBalancer, the system will deregister the instance before terminating it. This call simply registers a termination request. The termination of the instance can not happen immediately.
Returns the activity to terminate the instance.
321 322 323 324 325 326 |
# File 'lib/as/right_as_interface.rb', line 321 def terminate_instance_in_auto_scaling_group(instance_id, should_decrement_desired_capacity=true) request_hash = { 'InstanceId' => instance_id } request_hash['ShouldDecrementDesiredCapacity'] = should_decrement_desired_capacity link = generate_request('TerminateInstanceInAutoScalingGroup', request_hash ) request_info(link, DescribeScalingActivitiesParser.new(:logger => @logger))[:scaling_activities].first end |
#update_auto_scaling_group(auto_scaling_group_name, options = {}) ⇒ Object
Updates the configuration for the given AutoScalingGroup. If MaxSize is lower than the current size, then there will be an implicit call to SetDesiredCapacity to set the group to the new MaxSize. The same is true for MinSize there will also be an implicit call to SetDesiredCapacity. All optional parameters are left unchanged if not passed in the request.
The new settings are registered upon the completion of this call. Any launch configuration settings will take effect on any triggers after this call returns. However, triggers that are currently in progress can not be affected. See key term Trigger.
Returns true
or raises an exception.
Options: :launch_configuration_name
, :min_size
, :max_size
, :cooldown
, :availability_zones
. (Amazon’s notice: :availability_zones
is reserved for future use.)
as.update_auto_scaling_group('CentOS.5.1-c', :min_size => 1, :max_size => 4) #=> true
205 206 207 208 209 210 211 212 213 214 |
# File 'lib/as/right_as_interface.rb', line 205 def update_auto_scaling_group(auto_scaling_group_name, ={}) request_hash = amazonize_list('AvailabilityZones.member', [:availability_zones]) request_hash['AutoScalingGroupName'] = auto_scaling_group_name request_hash['LaunchConfigurationName'] = [:launch_configuration_name] if [:launch_configuration_name] request_hash['MinSize'] = [:min_size] if [:min_size] request_hash['MaxSize'] = [:max_size] if [:max_size] request_hash['Cooldown'] = [:cooldown] if [:cooldown] link = generate_request("UpdateAutoScalingGroup", request_hash) request_info(link, RightHttp2xxParser.new(:logger => @logger)) end |