class Aeolus::Image::Warehouse::Client

Public Class Methods

new(uri) click to toggle source
# File lib/aeolus_image/model/warehouse/warehouse_client.rb, line 170
def initialize(uri)
  @connection = Connection.new(uri)
end

Public Instance Methods

bucket(bucket) click to toggle source
# File lib/aeolus_image/model/warehouse/warehouse_client.rb, line 179
def bucket(bucket)
  Bucket.new bucket, @connection
end
buckets() click to toggle source
# File lib/aeolus_image/model/warehouse/warehouse_client.rb, line 183
def buckets
  @connection.do_request.xpath('/api/link[@rel="bucket"]').map do |obj|
    obj.at_xpath('./@href').to_s.gsub(%r.*\//, '')
  end
end
create_bucket(bucket) click to toggle source
# File lib/aeolus_image/model/warehouse/warehouse_client.rb, line 174
def create_bucket(bucket)
  @connection.do_request("/#{bucket}", :method => :put) rescue RestClient::InternalServerError
  Bucket.new(bucket, @connection)
end
get_iwhd_version() click to toggle source
# File lib/aeolus_image/model/warehouse/warehouse_client.rb, line 189
def get_iwhd_version
  result = @connection.do_request.at_xpath('/api[@service="image_warehouse"]/@version')
  raise "Response does not contain <api> tag or version information" if result == nil
  return result.value
end
query(bucket_name, query_string) click to toggle source
# File lib/aeolus_image/model/warehouse/warehouse_client.rb, line 195
def query(bucket_name, query_string)
  @connection.do_request "/#{bucket_name}/_query", {:method => :post, :content => query_string}
end