module ClientBucketMethods

Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the “License”); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an “AS IS” BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Public Instance Methods

blob_data(params) click to toggle source

RestClient doesn't do streaming 'get' yet - we already opened a pull request on this see github.com/archiloque/rest-client/issues/closed#issue/62 - apparently its going to be in the next version - unknown when. For now get full response. FIXME

# File lib/client_bucket_methods.rb, line 63
def blob_data(params)
  request(:get, "#{api_uri.to_s}/buckets/#{params['bucket']}/#{params[:id]}/content") do |response|
    response
  end
end

create_blob(params) { |blob| ... } click to toggle source

# File lib/client_bucket_methods.rb, line 34
def create_blob(params)
  blob = nil
  resource = RestClient::Resource.new("#{api_uri.to_s}/buckets/#{params['bucket']}", :open_timeout => 10, :timeout => 45)
  headers = default_headers.merge(extended_headers)
  unless params['metadata'].nil?
    metadata_headers = {}
    params['metadata'].each   do |k,v|
      metadata_headers["X-Deltacloud-Blobmeta-#{k}"] = v
    end
    headers = headers.merge(metadata_headers)
  end
  resource.send(:post, {:blob_data => File.new(params['file_path'], 'rb'), :blob_id => params[:id]}, headers) do |response, request, block|
    handle_backend_error(response) if response.code.eql?(500)
    blob = base_object(:blob, response)
    yield blob if block_given?
  end
  return blob
end

create_bucket(params) click to toggle source

# File lib/client_bucket_methods.rb, line 18
def create_bucket(params)
  obj = nil
  request(:post, "#{api_uri.to_s}/buckets", {:name => params['id'],:location=>params['bucket_location'] }) do |response|
    handle_backend_error(response) if response.code!=201
    obj = base_object(:bucket, response)
  end
end

destroy_blob(params) click to toggle source

# File lib/client_bucket_methods.rb, line 53
def destroy_blob(params)
  request(:delete, "#{api_uri.to_s}/buckets/#{params['bucket']}/#{params[:id]}") do |response|
    handle_backend_error(response) if response.code!=204
    nil if response.code == 204
  end
end

destroy_bucket(params) click to toggle source

# File lib/client_bucket_methods.rb, line 26
def destroy_bucket(params)
  #actually response here is 204 - no content - so nothing returned to client?
  request(:delete, "#{api_uri.to_s}/buckets/#{params['id']}") do |response|
    handle_backend_error(response) if response.code!=204
    nil if response.code == 204
  end
end