lib/oci/object_storage/transfer/upload_manager.rb
def upload_multipart(namespace_name, bucket_name, object_name, object_io_or_file_path, opts = {})
          assembler = OCI::ObjectStorage::Transfer::Multipart::MultipartObjectAssembler.new(
            object_storage_client: @object_storage_client,
            namespace: namespace_name,
            bucket_name: bucket_name,
            object_name: object_name,
            multipart_part_size: @upload_manager_config.multipart_part_size,
            non_file_io_multipart_part_size: @upload_manager_config.non_file_io_multipart_part_size,
            parallel_process_count: multipart_parallel_process_count,
            multipart_upload_opts: opts
          )

          upload_id = assembler.new_upload.data.upload_id
          assembler.io_for_transfer = object_io_or_file_path

          errors = assembler.upload

          # stdin is not resumable, so abort the upload if there were errors
          assembler.abort(upload_id) if !errors.empty? && object_io_or_file_path.eql?($stdin)

          unless errors.empty?
            raise OCI::Errors::MultipartUploadError.new(
              'Errors occurred while performing the multipart upload',
              errors,
              upload_id
            )
          end

          assembler.commit
        end
# The client used to interact with the Object Storage service
# @return [OCI::ObjectStorage::ObjectStorageClient]
The client used to interact with the Object Storage service
The client used to interact with the Object Storage service
def upload_multipart(namespace_name, bucket_name, object_name, object_io_or_file_path, opts = {})
          assembler = OCI::ObjectStorage::Transfer::Multipart::MultipartObjectAssembler.new(
            object_storage_client: @object_storage_client,
            namespace: namespace_name,
            bucket_name: bucket_name,
            object_name: object_name,
            multipart_part_size: @upload_manager_config.multipart_part_size,
            non_file_io_multipart_part_size: @upload_manager_config.non_file_io_multipart_part_size,
            parallel_process_count: multipart_parallel_process_count,
            multipart_upload_opts: opts
          )
          upload_id = assembler.new_upload.data.upload_id
          assembler.io_for_transfer = object_io_or_file_path
          errors = assembler.upload
          assembler.abort(upload_id) if !errors.empty? && object_io_or_file_path.eql?($stdin)
          unless errors.empty?
            raise OCI::Errors::MultipartUploadError.new(
              'Errors occurred while performing the multipart upload',
              errors,
              upload_id
            )
          end
          assembler.commit
        end
def upload_multipart ( namespace_name , bucket_name , object_name , object_io_or_file_path , opts = { } ) assembler = OCI :: ObjectStorage :: Transfer :: Multipart :: MultipartObjectAssembler . new ( object_storage_client : @object_storage_client , namespace : namespace_name , bucket_name : bucket_name , object_name : object_name , multipart_part_size : @upload_manager_config . multipart_part_size , non_file_io_multipart_part_size : @upload_manager_config . non_file_io_multipart_part_size , parallel_process_count : multipart_parallel_process_count , multipart_upload_opts : opts ) upload_id = assembler . new_upload . data . upload_id assembler . io_for_transfer = object_io_or_file_path errors = assembler . upload assembler . abort ( upload_id ) if ! errors . empty? && object_io_or_file_path . eql? ( $stdin ) unless errors . empty? raise OCI :: Errors :: MultipartUploadError . new ( 'Errors occurred while performing the multipart upload' , errors , upload_id ) end assembler . commit end
The client used to interact with the Object Storage service
The client used to interact with the Object Storage service
# stdin is not resumable, so abort the upload if there were errors
None
OCI::ObjectStorage::ObjectStorageClient
namespace_name
bucket_name
object_name
object_io_or_file_path
opts