Class: Aws::S3::MultipartUploadPart
- Inherits:
-
Object
- Object
- Aws::S3::MultipartUploadPart
- Extended by:
- Deprecations
- Defined in:
- lib/aws-sdk-s3/multipart_upload_part.rb
Defined Under Namespace
Classes: Collection
Read-Only Attributes collapse
- #bucket_name ⇒ String
-
#etag ⇒ String
Entity tag returned when the part was uploaded.
-
#last_modified ⇒ Time
Date and time at which the part was uploaded.
- #multipart_upload_id ⇒ String
- #object_key ⇒ String
- #part_number ⇒ Integer
-
#size ⇒ Integer
Size in bytes of the uploaded part data.
Actions collapse
- #copy_from(options = {}) ⇒ Types::UploadPartCopyOutput
- #upload(options = {}) ⇒ Types::UploadPartOutput
Associations collapse
- #identifiers ⇒ Object deprecated private Deprecated.
- #multipart_upload ⇒ MultipartUpload
Instance Method Summary collapse
- #client ⇒ Client
-
#data ⇒ Types::Part
Returns the data for this MultipartUploadPart.
-
#data_loaded? ⇒ Boolean
Returns ‘true` if this resource is loaded.
-
#initialize(*args) ⇒ MultipartUploadPart
constructor
A new instance of MultipartUploadPart.
- #load ⇒ Object (also: #reload) private
-
#wait_until(options = {}) {|resource| ... } ⇒ Resource
deprecated
Deprecated.
Use [Aws::S3::Client] #wait_until instead
Constructor Details
#initialize(bucket_name, object_key, multipart_upload_id, part_number, options = {}) ⇒ MultipartUploadPart #initialize(options = {}) ⇒ MultipartUploadPart
Returns a new instance of MultipartUploadPart.
26 27 28 29 30 31 32 33 34 35 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 26 def initialize(*args) = Hash === args.last ? args.pop.dup : {} @bucket_name = extract_bucket_name(args, ) @object_key = extract_object_key(args, ) @multipart_upload_id = extract_multipart_upload_id(args, ) @part_number = extract_part_number(args, ) @data = .delete(:data) @client = .delete(:client) || Client.new() @waiter_block_warned = false end |
Instance Method Details
#bucket_name ⇒ String
40 41 42 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 40 def bucket_name @bucket_name end |
#client ⇒ Client
80 81 82 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 80 def client @client end |
#copy_from(options = {}) ⇒ Types::UploadPartCopyOutput
280 281 282 283 284 285 286 287 288 289 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 280 def copy_from( = {}) = .merge( bucket: @bucket_name, key: @object_key, upload_id: @multipart_upload_id, part_number: @part_number ) resp = @client.upload_part_copy() resp.data end |
#data ⇒ Types::Part
Returns the data for this Aws::S3::MultipartUploadPart.
95 96 97 98 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 95 def data load unless @data @data end |
#data_loaded? ⇒ Boolean
103 104 105 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 103 def data_loaded? !!@data end |
#etag ⇒ String
Entity tag returned when the part was uploaded.
67 68 69 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 67 def etag data[:etag] end |
#identifiers ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
363 364 365 366 367 368 369 370 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 363 def identifiers { bucket_name: @bucket_name, object_key: @object_key, multipart_upload_id: @multipart_upload_id, part_number: @part_number } end |
#last_modified ⇒ Time
Date and time at which the part was uploaded.
61 62 63 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 61 def last_modified data[:last_modified] end |
#load ⇒ Object Also known as: reload
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
86 87 88 89 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 86 def load msg = "#load is not implemented, data only available via enumeration" raise NotImplementedError, msg end |
#multipart_upload ⇒ MultipartUpload
352 353 354 355 356 357 358 359 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 352 def multipart_upload MultipartUpload.new( bucket_name: @bucket_name, object_key: @object_key, id: @multipart_upload_id, client: @client ) end |
#multipart_upload_id ⇒ String
50 51 52 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 50 def multipart_upload_id @multipart_upload_id end |
#object_key ⇒ String
45 46 47 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 45 def object_key @object_key end |
#part_number ⇒ Integer
55 56 57 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 55 def part_number @part_number end |
#size ⇒ Integer
Size in bytes of the uploaded part data.
73 74 75 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 73 def size data[:size] end |
#upload(options = {}) ⇒ Types::UploadPartOutput
338 339 340 341 342 343 344 345 346 347 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 338 def upload( = {}) = .merge( bucket: @bucket_name, key: @object_key, upload_id: @multipart_upload_id, part_number: @part_number ) resp = @client.upload_part() resp.data end |
#wait_until(options = {}) {|resource| ... } ⇒ Resource
Use [Aws::S3::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
187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 |
# File 'lib/aws-sdk-s3/multipart_upload_part.rb', line 187 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::Waiters::Waiter.new().wait({}) end |