1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
require 'uri'
require 'rack/cache/meta_store'
require 'rack/cache/entity_store'
module Rack::Cache
# Maintains a collection of MetaStore and EntityStore instances keyed by
# URI. A single instance of this class can be used across a single process
# to ensure that only a single instance of a backing store is created per
# unique storage URI.
class Storage
def initialize
@metastores = {}
@entitystores = {}
end
def resolve_metastore_uri(uri, options = {})
@metastores[uri.to_s] ||= create_store(MetaStore, uri, options)
end
def resolve_entitystore_uri(uri, options = {})
@entitystores[uri.to_s] ||= create_store(EntityStore, uri, options)
end
def clear
@metastores.clear
@entitystores.clear
nil
end
private
def create_store(type, uri, options = {})
if uri.respond_to?(:scheme) || uri.respond_to?(:to_str)
uri = URI.parse(uri) unless uri.respond_to?(:scheme)
if type.const_defined?(uri.scheme.upcase)
klass = type.const_get(uri.scheme.upcase)
return klass.resolve(uri) if klass.method(:resolve).arity == 1
klass.resolve(uri, options)
else
fail "Unknown storage provider: #{uri.to_s}"
end
else
# hack in support for passing a Dalli::Client or Memcached object
# as the storage URI.
case
when defined?(::Dalli) && uri.kind_of?(::Dalli::Client)
type.const_get(:Dalli).resolve(uri)
when defined?(::Memcached) && uri.respond_to?(:stats)
type.const_get(:MemCached).resolve(uri)
else
fail "Unknown storage provider: #{uri.to_s}"
end
end
end
public
@@singleton_instance = new
def self.instance
@@singleton_instance
end
end
end
|
