# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 254 def blob_data(credentials, bucket, blob, opts={}) os = new_client(credentials, :buckets) safely do os.container(bucket).object(blob).data_stream do |chunk| yield chunk end end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 279 def blob_metadata(credentials, opts={}) os = new_client(credentials, :buckets) safely do os.container(opts['bucket']).object(opts[:id]).metadata end end
params: {:user,:password,:bucket,:blob,:content_type,:content_length,:metadata}
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 296 def blob_stream_connection(params) tokens = params[:user].split("+") user_name, tenant_name = tokens.first, tokens.last #need a client for the auth_token and endpoints os = OpenStack::Connection.create(:username => user_name, :api_key => params[:password], :authtenant => tenant_name, :auth_url => api_provider, :service_type => "object-store") http = Net::HTTP.new(os.connection.service_host, os.connection.service_port) http.use_ssl = true http.verify_mode = OpenSSL::SSL::VERIFY_NONE path = os.connection.service_path + URI.encode("/#{params[:bucket]}/#{params[:blob]}") request = Net::HTTP::Put.new(path) request['X-Auth-Token'] = os.connection.authtoken request['X-Storage-Token'] = os.connection.authtoken request['Connection'] = "Keep-Alive" request['Content-Type'] = params[:content_type] request['Content-Length'] = params[:content_length] request['Expect'] = "100-continue" metadata = params[:metadata] || {} BlobHelper::rename_metadata_headers(metadata, 'X-Object-Meta-') metadata.each{|k,v| request[k] = v} return http, request end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 240 def blobs(credentials, opts={}) os = new_client(credentials, :buckets) blobs = [] safely do bucket = os.container(opts['bucket']) if(opts[:id]) blobs << convert_blob(bucket.object(opts[:id]), opts['bucket']) else bucket.objects_detail.each{|blob| blobs << convert_blob(blob, opts['bucket'])} end end blobs end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 211 def buckets(credentials, opts={}) os = new_client(credentials, :buckets) buckets = [] safely do if opts[:id] buckets << convert_bucket(os.container(opts[:id])) else os.containers.each{|bucket_name| buckets << convert_bucket(os.container(bucket_name))} end end buckets end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 263 def create_blob(credentials, bucket, blob, data, opts={}) os = new_client(credentials, :buckets) safely do BlobHelper.rename_metadata_headers(opts, "X-Object-Meta-") os_blob = os.container(bucket).create_object(blob, {:content_type=> data[:type], :metadata=>opts}, data[:tempfile]) convert_blob(os_blob, bucket) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 224 def create_bucket(credentials, name, opts={}) os = new_client(credentials, :buckets) bucket = nil safely do bucket = os.create_container(name) end convert_bucket(bucket) end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 98 def create_image(credentials, opts) os = new_client(credentials) safely do server = os.get_server(opts[:id]) image_name = opts[:name] || "#{server.name}_#{Time.now}" img = server.create_image(:name=>image_name) convert_from_image(img, os.connection.authuser) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 159 def create_instance(credentials, image_id, opts) os = new_client( credentials ) result = nil #opts[:personality]: path1='server_path1'. content1='contents1', path2='server_path2', content2='contents2' etc params = {} params[:personality] = extract_personality(opts) params[:name] = (opts[:name] && opts[:name].length>0)? opts[:name] : "server#{Time.now.to_s}" params[:imageRef] = image_id params[:flavorRef] = (opts[:hwp_id] && opts[:hwp_id].length>0) ? opts[:hwp_id] : hardware_profiles(credentials).first.name if opts[:password] && opts[:password].length > 0 params[:adminPass]=opts[:password] end if opts[:keyname] && opts[:keyname].length > 0 params[:key_name]=opts[:keyname] end safely do server = os.create_server(params) result = convert_from_server(server, os.connection.authuser) end result end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 327 def create_key(credentials, opts={}) os = new_client(credentials) safely do params = (opts[:public_key] and opts[:public_key].length > 0)? {:name=>opts[:key_name], :public_key=> opts[:public_key]} : {:name=>opts[:key_name]} convert_key(os.create_keypair(params)) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 272 def delete_blob(credentials, bucket, blob, opts={}) os = new_client(credentials, :buckets) safely do os.container(bucket).delete_object(blob) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 233 def delete_bucket(credentials, name, opts={}) os = new_client(credentials, :buckets) safely do os.delete_container(name) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 108 def destroy_image(credentials, image_id) os = new_client(credentials) begin image = os.get_image(image_id) image.delete! rescue => e raise Deltacloud::ExceptionHandler::BackendError.new(e, "ERROR: Cannot delete image with ID:#{image_id}.") end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 191 def destroy_instance(credentials, instance_id) os = new_client(credentials) safely do server = os.get_server(instance_id) server.delete! convert_from_server(server, os.connection.authuser) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 335 def destroy_key(credentials, opts={}) os = new_client(credentials) safely do os.delete_keypair(opts[:id]) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 54 def hardware_profiles(credentials, opts = {}) os = new_client(credentials) results = [] safely do if opts[:id] begin flavor = os.flavor(opts[:id]) results << convert_from_flavor(flavor) rescue => e raise e unless e.message =~ %rThe resource could not be found/ results = [] end else results = os.flavors.collect do |f| convert_from_flavor(f) end end filter_hardware_profiles(results, opts) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 75 def images(credentials, opts={}) os = new_client(credentials) results = [] profiles = hardware_profiles(credentials) safely do if(opts[:id]) begin img = os.get_image(opts[:id]) results << convert_from_image(img, os.connection.authuser) rescue => e raise e unless e.message =~ %rImage not found/ results = [] end else results = os.list_images.collect do |i| convert_from_image(i, os.connection.authuser) end end end results.each { |img| img.hardware_profiles = profiles } filter_on(results, :owner_id, opts) end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 137 def instances(credentials, opts={}) os = new_client(credentials) insts = [] safely do if opts[:id] begin server = os.get_server(opts[:id]) insts << convert_from_server(server, os.connection.authuser) rescue => e raise e unless e.message =~ %rThe resource could not be found/ insts = [] end else insts = os.list_servers_detail.collect do |s| convert_from_server(s, os.connection.authuser) end end end insts = filter_on( insts, :state, opts ) insts end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 318 def keys(credentials, opts={}) os = new_client(credentials) keys = [] safely do os.keypairs.values.each{|key| keys << convert_key(key)} end filter_on(keys, :id, opts) end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 118 def realms(credentials, opts={}) os = new_client(credentials) limits = "" safely do lim = os.limits limits << "ABSOLUTE >> Max. Instances: #{lim[:absolute][:maxTotalInstances]} Max. RAM: #{lim[:absolute][:maxTotalRAMSize]} || " lim[:rate].each do |rate| if rate[:regex] =~ %rservers/ limits << "SERVERS >> Total: #{rate[:limit].first[:value]} Remaining: #{rate[:limit].first[:remaining]} Time Unit: per #{rate[:limit].first[:unit]}" end end end return [] if opts[:id] and opts[:id] != 'default' [ Realm.new( { :id=>'default', :name=>'default', :limit => limits, :state=>'AVAILABLE' })] end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 182 def reboot_instance(credentials, instance_id) os = new_client(credentials) safely do server = os.get_server(instance_id) server.reboot! # sends a hard reboot (power cycle) - could instead server.reboot("SOFT") convert_from_server(server, os.connection.authuser) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 43 def supported_collections(credentials) #get the collections as defined by 'capability' and 'respond_to?' blocks super_collections = super begin client = new_client(credentials, :buckets) rescue Deltacloud::ExceptionHandler::NotImplemented #OpenStack::Exception::NotImplemented... return super_collections - [Sinatra::Rabbit::BucketsCollection] end super_collections end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 286 def update_blob_metadata(credentials, opts={}) os = new_client(credentials, :buckets) safely do BlobHelper.rename_metadata_headers(opts["meta_hash"], "") blob = os.container(opts['bucket']).object(opts[:id]) blob.set_metadata(opts['meta_hash']) end end
# File lib/deltacloud/drivers/openstack/openstack_driver.rb, line 202 def valid_credentials?(credentials) begin new_client(credentials) rescue return false end true end