Module: Seabright::Storage::ClassMethods

Defined in:
lib/redis_object/storage.rb

Instance Method Summary collapse

Instance Method Details

#adapter ⇒ Object 



45
46
47
 
# File 'lib/redis_object/storage.rb', line 45

def adapter
	@adapter ||= config[:adapter].to_sym || :Redis
end

#adapters ⇒ Object 



41
42
43
 
# File 'lib/redis_object/storage.rb', line 41

def adapters
	@@adapters ||= {}
end

#config(id = store_name) ⇒ Object 



57
58
59
 
# File 'lib/redis_object/storage.rb', line 57

def config(id=store_name)
	configs[id]
end

#configs ⇒ Object 



53
54
55
 
# File 'lib/redis_object/storage.rb', line 53

def configs
	@@conf ||= {}
end

#configure_store(conf, id = store_name, *ids) ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/redis_object/storage.rb', line 22

def configure_store(conf,id=store_name,*ids)
	configs[id] = conf
	ids.each do |i|
		configs[i] = conf
	end
	store(id)
end

#dump_stores_to_files(path) ⇒ Object 



65
66
67
68
69
70
71
72
73
 
# File 'lib/redis_object/storage.rb', line 65

def dump_stores_to_files(path)
	raise "Directory does not exist!" unless Dir.exists?(File.dirname(path))
	adapters.each do |name,adptr|
		if adptr.respond_to? :dump_to_file
			Log.info "Dumping #{name} into #{path}/#{name.to_s}.dump"
			adptr.dump_to_file("#{path}/#{name.to_s}.dump")
		end
	end
end

#reconnect! ⇒ Object 



35
36
37
38
39
 
# File 'lib/redis_object/storage.rb', line 35

def reconnect!
	adapters.each do |k,v|
		v.reconnect!
	end
end

#restore_stores_from_files(path) ⇒ Object 



75
76
77
78
79
80
81
82
83
84
 
# File 'lib/redis_object/storage.rb', line 75

def restore_stores_from_files(path)
	raise "Directory does not exist!" unless Dir.exists?(File.dirname(path))
	Dir.glob(path + "/*.dump").each do |file|
		name = file.gsub(/\.[^\.]+$/,'').gsub(/.*\//,'').to_sym
		if (stor = store(name)) && stor.respond_to?(:restore_from_file)
			Log.info "Restoring #{name} from #{file}"
			stor.restore_from_file(file)
		end
	end
end

#set_storage(adp = adapter) ⇒ Object 



14
15
16
 
# File 'lib/redis_object/storage.rb', line 14

def set_storage(adp=adapter)
	@adapter = adp
end

#store(id = store_name) ⇒ Object 



18
19
20
 
# File 'lib/redis_object/storage.rb', line 18

def store(id=store_name)
	adapters[id] ||= const_get(adapter).new(config(id))
end

#store_name ⇒ Object 



49
50
51
 
# File 'lib/redis_object/storage.rb', line 49

def store_name
	@store_name ||= :global
end

#stores ⇒ Object 



61
62
63
 
# File 'lib/redis_object/storage.rb', line 61

def stores
	adapters
end

#use_store(id) ⇒ Object 



30
31
32
33
 
# File 'lib/redis_object/storage.rb', line 30

def use_store(id)
	raise "Cannot use non-existent store: #{id}" unless config(id)
	@store_name = id.to_sym
end