Sha256: d9155cc99baf050c76a4aa1d6ce0677a57363b8788efbe84addb91696ae84502
Contents?: true
Size: 1.43 KB
Versions: 105
Compression:
Stored size: 1.43 KB
Contents
# Copyright (c) 2009-2012 VMware, Inc.
module Bosh
module Blobstore
class LocalClient < BaseClient
CHUNK_SIZE = 1024 * 1024
def initialize(options)
super(options)
@blobstore_path = URI(@options[:blobstore_path]).path
raise "No blobstore path given in options #{@options}" if @blobstore_path.nil?
FileUtils.mkdir_p(@blobstore_path) unless File.directory?(@blobstore_path)
end
protected
def create_file(id, file)
id ||= generate_object_id
dst = object_file_path(id)
raise BlobstoreError, "object id #{id} is already in use" if File.exist?(dst)
File.open(dst, 'w') do |fh|
fh.write(file.read(CHUNK_SIZE)) until file.eof?
end
id
end
def get_file(id, file)
src = object_file_path(id)
begin
File.open(src, 'r') do |src_fh|
file.write(src_fh.read(CHUNK_SIZE)) until src_fh.eof?
end
end
rescue Errno::ENOENT
raise NotFound, "Blobstore object '#{id}' not found"
end
def delete_object(id)
file = object_file_path(id)
FileUtils.rm(file)
rescue Errno::ENOENT
raise NotFound, "Blobstore object '#{id}' not found"
end
def object_exists?(oid)
File.exist?(object_file_path(oid))
end
private
def object_file_path(oid)
File.join(@blobstore_path, oid)
end
end
end
end
Version data entries
105 entries across 105 versions & 1 rubygems