Class: Aws::EC2::Volume
- Inherits:
-
Object
- Object
- Aws::EC2::Volume
- Defined in:
- gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb
Defined Under Namespace
Classes: Collection
Read-Only Attributes collapse
-
#attachments ⇒ Array<Types::VolumeAttachment>
This parameter is not returned by CreateVolume. -
#availability_zone ⇒ String
The Availability Zone for the volume.
-
#availability_zone_id ⇒ String
The ID of the Availability Zone for the volume.
-
#create_time ⇒ Time
The time stamp when volume creation was initiated.
-
#encrypted ⇒ Boolean
Indicates whether the volume is encrypted.
-
#fast_restored ⇒ Boolean
This parameter is not returned by CreateVolume. -
#id ⇒ String
(also: #volume_id)
-
#iops ⇒ Integer
The number of I/O operations per second (IOPS).
-
#kms_key_id ⇒ String
The Amazon Resource Name (ARN) of the KMS key that was used to protect the volume encryption key for the volume.
-
#multi_attach_enabled ⇒ Boolean
Indicates whether Amazon EBS Multi-Attach is enabled.
-
#operator ⇒ Types::OperatorResponse
The service provider that manages the volume.
-
#outpost_arn ⇒ String
The Amazon Resource Name (ARN) of the Outpost.
-
#size ⇒ Integer
The size of the volume, in GiBs.
-
#snapshot_id ⇒ String
The snapshot from which the volume was created, if applicable.
-
#sse_type ⇒ String
This parameter is not returned by CreateVolume. -
#state ⇒ String
The volume state.
-
#tags ⇒ Array<Types::Tag>
Any tags assigned to the volume.
-
#throughput ⇒ Integer
The throughput that the volume supports, in MiB/s.
-
#volume_initialization_rate ⇒ Integer
The Amazon EBS Provisioned Rate for Volume Initialization (volume initialization rate) specified for the volume during creation, in MiB/s.
-
#volume_type ⇒ String
The volume type.
Actions collapse
-
#attach_to_instance(options = {}) ⇒ Types::VolumeAttachment
-
#create_snapshot(options = {}) ⇒ Snapshot
-
#create_tags(options = {}) ⇒ Tag::Collection
-
#delete(options = {}) ⇒ EmptyStructure
-
#delete_tags(options = {}) ⇒ Tag::Collection
-
#describe_attribute(options = {}) ⇒ Types::DescribeVolumeAttributeResult
-
#describe_status(options = {}) ⇒ Types::DescribeVolumeStatusResult
-
#detach_from_instance(options = {}) ⇒ Types::VolumeAttachment
-
#enable_io(options = {}) ⇒ EmptyStructure
-
#modify_attribute(options = {}) ⇒ EmptyStructure
Associations collapse
Instance Method Summary collapse
-
#client ⇒ Client
-
#data ⇒ Types::Volume
Returns the data for this Volume.
-
#data_loaded? ⇒ Boolean
Returns
true
if this resource is loaded. -
#initialize(*args) ⇒ Volume
constructor
A new instance of Volume.
- #load ⇒ self (also: #reload)
-
#wait_until(options = {}) {|resource| ... } ⇒ Resource
deprecated
Deprecated.
Use [Aws::EC2::Client] #wait_until instead
Constructor Details
#initialize(id, options = {}) ⇒ Volume #initialize(options = {}) ⇒ Volume
Returns a new instance of Volume.
22 23 24 25 26 27 28 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 22 def initialize(*args) = Hash === args.last ? args.pop.dup : {} @id = extract_id(args, ) @data = .delete(:data) @client = .delete(:client) || Client.new() @waiter_block_warned = false end |
Instance Method Details
#attach_to_instance(options = {}) ⇒ Types::VolumeAttachment
328 329 330 331 332 333 334 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 328 def attach_to_instance( = {}) = .merge(volume_id: @id) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.attach_volume() end resp.data end |
#attachments ⇒ Array<Types::VolumeAttachment>
Information about the volume attachments.
155 156 157 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 155 def data[:attachments] end |
#availability_zone ⇒ String
The Availability Zone for the volume.
133 134 135 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 133 def availability_zone data[:availability_zone] end |
#availability_zone_id ⇒ String
The ID of the Availability Zone for the volume.
40 41 42 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 40 def availability_zone_id data[:availability_zone_id] end |
#client ⇒ Client
175 176 177 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 175 def client @client end |
#create_snapshot(options = {}) ⇒ Snapshot
398 399 400 401 402 403 404 405 406 407 408 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 398 def create_snapshot( = {}) = .merge(volume_id: @id) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.create_snapshot() end Snapshot.new( id: resp.data.snapshot_id, data: resp.data, client: @client ) end |
#create_tags(options = {}) ⇒ Tag::Collection
432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 432 def ( = {}) batch = [] = Aws::Util.deep_merge(, resources: [@id]) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.() end [:tags].each do |t| batch << Tag.new( resource_id: @id, key: t[:key], value: t[:value], client: @client ) end Tag::Collection.new([batch], size: batch.size) end |
#create_time ⇒ Time
The time stamp when volume creation was initiated.
145 146 147 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 145 def create_time data[:create_time] end |
#data ⇒ Types::Volume
Returns the data for this Aws::EC2::Volume. Calls
Client#describe_volumes if #data_loaded? is false
.
197 198 199 200 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 197 def data load unless @data @data end |
#data_loaded? ⇒ Boolean
205 206 207 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 205 def data_loaded? !!@data end |
#delete(options = {}) ⇒ EmptyStructure
508 509 510 511 512 513 514 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 508 def delete( = {}) = .merge(volume_id: @id) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.delete_volume() end resp.data end |
#delete_tags(options = {}) ⇒ Tag::Collection
479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 479 def ( = {}) batch = [] = Aws::Util.deep_merge(, resources: [@id]) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.() end [:tags].each do |t| batch << Tag.new( resource_id: @id, key: t[:key], value: t[:value], client: @client ) end Tag::Collection.new([batch], size: batch.size) end |
#describe_attribute(options = {}) ⇒ Types::DescribeVolumeAttributeResult
531 532 533 534 535 536 537 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 531 def describe_attribute( = {}) = .merge(volume_id: @id) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.describe_volume_attribute() end resp.data end |
#describe_status(options = {}) ⇒ Types::DescribeVolumeStatusResult
604 605 606 607 608 609 610 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 604 def describe_status( = {}) = Aws::Util.deep_merge(, volume_ids: [@id]) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.describe_volume_status() end resp.data end |
#detach_from_instance(options = {}) ⇒ Types::VolumeAttachment
641 642 643 644 645 646 647 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 641 def detach_from_instance( = {}) = .merge(volume_id: @id) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.detach_volume() end resp.data end |
#enable_io(options = {}) ⇒ EmptyStructure
661 662 663 664 665 666 667 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 661 def enable_io( = {}) = .merge(volume_id: @id) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.enable_volume_io() end resp.data end |
#encrypted ⇒ Boolean
Indicates whether the volume is encrypted.
161 162 163 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 161 def encrypted data[:encrypted] end |
#fast_restored ⇒ Boolean
Indicates whether the volume was created using fast snapshot restore.
78 79 80 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 78 def fast_restored data[:fast_restored] end |
#id ⇒ String Also known as: volume_id
33 34 35 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 33 def id @id end |
#iops ⇒ Integer
The number of I/O operations per second (IOPS). For gp3
, io1
, and
io2
volumes, this represents the number of IOPS that are provisioned
for the volume. For gp2
volumes, this represents the baseline
performance of the volume and the rate at which the volume accumulates
I/O credits for bursting.
56 57 58 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 56 def iops data[:iops] end |
#kms_key_id ⇒ String
The Amazon Resource Name (ARN) of the KMS key that was used to protect the volume encryption key for the volume.
168 169 170 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 168 def kms_key_id data[:kms_key_id] end |
#load ⇒ self Also known as: reload
Loads, or reloads #data for the current Aws::EC2::Volume.
Returns self
making it possible to chain methods.
volume.reload.data
185 186 187 188 189 190 191 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 185 def load resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.describe_volumes(volume_ids: [@id]) end @data = resp.volumes[0] self end |
#modify_attribute(options = {}) ⇒ EmptyStructure
687 688 689 690 691 692 693 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 687 def modify_attribute( = {}) = .merge(volume_id: @id) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.modify_volume_attribute() end resp.data end |
#multi_attach_enabled ⇒ Boolean
Indicates whether Amazon EBS Multi-Attach is enabled.
84 85 86 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 84 def multi_attach_enabled data[:multi_attach_enabled] end |
#operator ⇒ Types::OperatorResponse
The service provider that manages the volume.
106 107 108 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 106 def operator data[:operator] end |
#outpost_arn ⇒ String
The Amazon Resource Name (ARN) of the Outpost.
46 47 48 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 46 def outpost_arn data[:outpost_arn] end |
#size ⇒ Integer
The size of the volume, in GiBs.
121 122 123 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 121 def size data[:size] end |
#snapshot_id ⇒ String
The snapshot from which the volume was created, if applicable.
127 128 129 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 127 def snapshot_id data[:snapshot_id] end |
#snapshots(options = {}) ⇒ Snapshot::Collection
775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 775 def snapshots( = {}) batches = Enumerator.new do |y| = Aws::Util.deep_merge(, filters: [{ name: "volume-id", values: [@id] }]) resp = Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do @client.describe_snapshots() end resp.each_page do |page| batch = [] page.data.snapshots.each do |s| batch << Snapshot.new( id: s.snapshot_id, data: s, client: @client ) end y.yield(batch) end end Snapshot::Collection.new(batches) end |
#sse_type ⇒ String
Reserved for future use.
100 101 102 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 100 def sse_type data[:sse_type] end |
#state ⇒ String
The volume state.
139 140 141 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 139 def state data[:state] end |
#tags ⇒ Array<Types::Tag>
Any tags assigned to the volume.
62 63 64 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 62 def data[:tags] end |
#throughput ⇒ Integer
The throughput that the volume supports, in MiB/s.
90 91 92 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 90 def throughput data[:throughput] end |
#volume_initialization_rate ⇒ Integer
The Amazon EBS Provisioned Rate for Volume Initialization (volume
initialization rate) specified for the volume during creation, in
MiB/s. If no volume initialization rate was specified, the value is
null
.
115 116 117 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 115 def volume_initialization_rate data[:volume_initialization_rate] end |
#volume_type ⇒ String
The volume type.
68 69 70 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 68 def volume_type data[:volume_type] end |
#wait_until(options = {}) {|resource| ... } ⇒ Resource
Use [Aws::EC2::Client] #wait_until instead
The waiting operation is performed on a copy. The original resource remains unchanged.
Waiter polls an API operation until a resource enters a desired state.
Basic Usage
Waiter will polls until it is successful, it fails by entering a terminal state, or until a maximum number of attempts are made.
# polls in a loop until condition is true
resource.wait_until() {|resource| condition}
Example
instance.wait_until(max_attempts:10, delay:5) do |instance|
instance.state.name == 'running'
end
Configuration
You can configure the maximum number of polling attempts, and the delay (in seconds) between each polling attempt. The waiting condition is set by passing a block to #wait_until:
# poll for ~25 seconds
resource.wait_until(max_attempts:5,delay:5) {|resource|...}
Callbacks
You can be notified before each polling attempt and before each
delay. If you throw :success
or :failure
from these callbacks,
it will terminate the waiter.
started_at = Time.now
# poll for 1 hour, instead of a number of attempts
proc = Proc.new do |attempts, response|
throw :failure if Time.now - started_at > 3600
end
# disable max attempts
instance.wait_until(before_wait:proc, max_attempts:nil) {...}
Handling Errors
When a waiter is successful, it returns the Resource. When a waiter fails, it raises an error.
begin
resource.wait_until(...)
rescue Aws::Waiters::Errors::WaiterFailed
# resource did not enter the desired state in time
end
attempts attempt in seconds invoked before each attempt invoked before each wait
289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 289 def wait_until( = {}, &block) self_copy = self.dup attempts = 0 [:max_attempts] = 10 unless .key?(:max_attempts) [:delay] ||= 10 [:poller] = Proc.new do attempts += 1 if block.call(self_copy) [:success, self_copy] else self_copy.reload unless attempts == [:max_attempts] :retry end end Aws::Plugins::UserAgent.metric('RESOURCE_MODEL') do Aws::Waiters::Waiter.new().wait({}) end end |