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
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_list, #cache_hits?, caching, caching=, #caching?, #destroy_connection, #generate_request_impl, #get_connection, #get_connections_storage, #get_server_url, #init, #on_exception, #request_cache_or_info, #request_info_impl, #signed_service_params, #update_cache
Methods inherited from RightAwsBase
amazon_problems, amazon_problems=
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 -
:multi_thread
: true=HTTP connection per thread, false=per process -
: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
103 104 105 106 107 108 109 110 111 112 113 |
# File 'lib/as/right_as_interface.rb', line 103 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
152 153 154 155 156 157 158 159 160 161 162 163 164 165 |
# File 'lib/as/right_as_interface.rb', line 152 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
354 355 356 357 358 359 360 361 362 363 364 365 366 |
# File 'lib/as/right_as_interface.rb', line 354 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].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].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
474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 |
# File 'lib/as/right_as_interface.rb', line 474 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.
170 171 172 173 |
# File 'lib/as/right_as_interface.rb', line 170 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
441 442 443 444 |
# File 'lib/as/right_as_interface.rb', line 441 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
527 528 529 530 531 |
# File 'lib/as/right_as_interface.rb', line 527 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.
135 136 137 138 139 140 |
# File 'lib/as/right_as_interface.rb', line 135 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.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=>""}, ...]
385 386 387 388 389 390 391 392 |
# File 'lib/as/right_as_interface.rb', line 385 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}]}
246 247 248 249 250 251 252 253 |
# File 'lib/as/right_as_interface.rb', line 246 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}]
517 518 519 520 |
# File 'lib/as/right_as_interface.rb', line 517 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:
115 116 117 |
# File 'lib/as/right_as_interface.rb', line 115 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
420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 |
# File 'lib/as/right_as_interface.rb', line 420 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].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
293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 |
# File 'lib/as/right_as_interface.rb', line 293 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].blank? end last_response end |
#request_info(request, parser) ⇒ Object
Sends request to Amazon and parses the response Raises AwsError if any banana happened
121 122 123 |
# File 'lib/as/right_as_interface.rb', line 121 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
184 185 186 187 188 |
# File 'lib/as/right_as_interface.rb', line 184 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.
322 323 324 325 326 327 |
# File 'lib/as/right_as_interface.rb', line 322 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
206 207 208 209 210 211 212 213 214 215 |
# File 'lib/as/right_as_interface.rb', line 206 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 |