Module: CacheVersion
- Defined in:
- lib/cache_version.rb
Class Method Summary collapse
- .cache ⇒ Object
- .clear_cache ⇒ Object
- .db ⇒ Object
- .get(key) ⇒ Object
- .increment(key) ⇒ Object
- .invalidate_cache(key) ⇒ Object
Class Method Details
.cache ⇒ Object
14 15 16 |
# File 'lib/cache_version.rb', line 14 def self.cache CACHE end |
.clear_cache ⇒ Object
42 43 44 |
# File 'lib/cache_version.rb', line 42 def self.clear_cache @version_by_key = {} end |
.db ⇒ Object
6 7 8 9 10 11 12 |
# File 'lib/cache_version.rb', line 6 def self.db if @db.nil? @db = ActiveRecord::Base.connection @db = @db.send(:master) if defined?(DataFabric::ConnectionProxy) and @db.kind_of?(DataFabric::ConnectionProxy) end @db end |
.get(key) ⇒ Object
18 19 20 21 22 23 |
# File 'lib/cache_version.rb', line 18 def self.get(key) key = key.to_s version_by_key[key] ||= CACHE.get_or_set(cache_key(key)) do db.select_value("SELECT version FROM cache_versions WHERE key = '#{key}'").to_i end end |
.increment(key) ⇒ Object
25 26 27 28 29 30 31 32 33 34 |
# File 'lib/cache_version.rb', line 25 def self.increment(key) key = key.to_s if get(key) == 0 db.execute("INSERT INTO cache_versions (key, version) VALUES ('#{key}', 1)") else db.execute("UPDATE cache_versions SET version = version + 1 WHERE key = '#{key}'") end invalidate_cache(key) get(key) end |
.invalidate_cache(key) ⇒ Object
36 37 38 39 40 |
# File 'lib/cache_version.rb', line 36 def self.invalidate_cache(key) key = key.to_s cache.delete(cache_key(key)) version_by_key.delete(key) end |