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.
-
#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 entity 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_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
313 314 315 316 317 318 319 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 313 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.
140 141 142 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 140 def data[:attachments] end |
#availability_zone ⇒ String
The Availability Zone for the volume.
118 119 120 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 118 def availability_zone data[:availability_zone] end |
#client ⇒ Client
160 161 162 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 160 def client @client end |
#create_snapshot(options = {}) ⇒ Snapshot
371 372 373 374 375 376 377 378 379 380 381 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 371 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
405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 405 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.
130 131 132 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 130 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
.
182 183 184 185 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 182 def data load unless @data @data end |
#data_loaded? ⇒ Boolean
190 191 192 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 190 def data_loaded? !!@data end |
#delete(options = {}) ⇒ EmptyStructure
481 482 483 484 485 486 487 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 481 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
452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 452 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
504 505 506 507 508 509 510 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 504 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
577 578 579 580 581 582 583 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 577 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
614 615 616 617 618 619 620 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 614 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
634 635 636 637 638 639 640 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 634 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.
146 147 148 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 146 def encrypted data[:encrypted] end |
#fast_restored ⇒ Boolean
Indicates whether the volume was created using fast snapshot restore.
72 73 74 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 72 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.
50 51 52 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 50 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.
153 154 155 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 153 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
170 171 172 173 174 175 176 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 170 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
660 661 662 663 664 665 666 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 660 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.
78 79 80 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 78 def multi_attach_enabled data[:multi_attach_enabled] end |
#operator ⇒ Types::OperatorResponse
The entity that manages the volume.
100 101 102 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 100 def operator data[:operator] end |
#outpost_arn ⇒ String
The Amazon Resource Name (ARN) of the Outpost.
40 41 42 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 40 def outpost_arn data[:outpost_arn] end |
#size ⇒ Integer
The size of the volume, in GiBs.
106 107 108 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 106 def size data[:size] end |
#snapshot_id ⇒ String
The snapshot from which the volume was created, if applicable.
112 113 114 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 112 def snapshot_id data[:snapshot_id] end |
#snapshots(options = {}) ⇒ Snapshot::Collection
745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 745 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.
94 95 96 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 94 def sse_type data[:sse_type] end |
#state ⇒ String
The volume state.
124 125 126 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 124 def state data[:state] end |
#tags ⇒ Array<Types::Tag>
Any tags assigned to the volume.
56 57 58 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 56 def data[:tags] end |
#throughput ⇒ Integer
The throughput that the volume supports, in MiB/s.
84 85 86 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 84 def throughput data[:throughput] end |
#volume_type ⇒ String
The volume type.
62 63 64 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 62 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
274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 |
# File 'gems/aws-sdk-ec2/lib/aws-sdk-ec2/volume.rb', line 274 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 |