Class: RedisCacheStore
- Inherits:
-
Object
- Object
- RedisCacheStore
- Defined in:
- lib/cache_store_redis.rb
Overview
This class is used to implement a redis cache store. This class is used for interacting with a redis based cache store.
Class Method Summary collapse
Instance Method Summary collapse
-
#configure(host = 'localhost', port = 6379, db = 'default', password = nil, driver: nil, url: nil) ⇒ Object
This method is called to configure the connection to the cache store.
-
#exist?(key) ⇒ Boolean
This method is called to check if a value exists within this cache store for a specific key.
-
#get(key, expires_in = 0, &block) ⇒ Object
This method is called to get a value from this cache store by it’s unique key.
-
#initialize(namespace = nil, config = nil) ⇒ RedisCacheStore
constructor
A new instance of RedisCacheStore.
-
#ping ⇒ String
Ping the cache store.
-
#remove(key) ⇒ Object
This method is called to remove a value from this cache store by it’s unique key.
-
#set(key, value, expires_in = 0) ⇒ Object
This method is called to set a value within this cache store by it’s key.
- #with_client ⇒ Object
Constructor Details
#initialize(namespace = nil, config = nil) ⇒ RedisCacheStore
Returns a new instance of RedisCacheStore.
28 29 30 31 32 33 34 35 36 |
# File 'lib/cache_store_redis.rb', line 28 def initialize(namespace = nil, config = nil) if RUBY_PLATFORM != 'java' require 'oj' end @namespace = namespace @config = config end |
Class Method Details
.pool(config) ⇒ Object
10 11 12 13 14 15 16 17 18 |
# File 'lib/cache_store_redis.rb', line 10 def self.pool(config) @pool ||= ConnectionPool.new(size: pool_size, timeout: pool_timeout) do if config == nil Redis.new else Redis.new(config) end end end |
.pool_size ⇒ Object
20 21 22 |
# File 'lib/cache_store_redis.rb', line 20 def self.pool_size @pool_size ||= ENV['CACHE_STORE_POOL_SIZE'] || 10 end |
.pool_timeout ⇒ Object
24 25 26 |
# File 'lib/cache_store_redis.rb', line 24 def self.pool_timeout @pool_size ||= ENV['CACHE_STORE_POOL_TIMEOUT'] || 1 end |
Instance Method Details
#configure(host = 'localhost', port = 6379, db = 'default', password = nil, driver: nil, url: nil) ⇒ Object
This method is called to configure the connection to the cache store.
45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
# File 'lib/cache_store_redis.rb', line 45 def configure(host = 'localhost', port = 6379, db = 'default', password = nil, driver: nil, url: nil) if url != nil config[:url] = url config[:db] = db else config = { :host => host, :port => port, :db => db } end if password != nil config[:password] = password end if driver != nil config[:driver] = driver end end |
#exist?(key) ⇒ Boolean
This method is called to check if a value exists within this cache store for a specific key.
122 123 124 125 126 |
# File 'lib/cache_store_redis.rb', line 122 def exist?(key) with_client do |client| client.exists(build_key(key)) end end |
#get(key, expires_in = 0, &block) ⇒ Object
This method is called to get a value from this cache store by it’s unique key.
91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 |
# File 'lib/cache_store_redis.rb', line 91 def get(key, expires_in = 0, &block) k = build_key(key) value = with_client do |client| client.get(k) end value = deserialize(value) unless value == nil if value.nil? && block_given? value = yield set(k, value, expires_in) end return value end |
#ping ⇒ String
Ping the cache store.
131 132 133 134 135 |
# File 'lib/cache_store_redis.rb', line 131 def ping with_client do |client| client.ping end end |
#remove(key) ⇒ Object
This method is called to remove a value from this cache store by it’s unique key.
112 113 114 115 116 |
# File 'lib/cache_store_redis.rb', line 112 def remove(key) with_client do |client| client.del(build_key(key)) end end |
#set(key, value, expires_in = 0) ⇒ Object
This method is called to set a value within this cache store by it’s key.
65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 |
# File 'lib/cache_store_redis.rb', line 65 def set(key, value, expires_in = 0) v = nil k = build_key(key) if value != nil v = serialize(value) end with_client do |client| client.multi do client.set(k, v) if expires_in > 0 client.expire(k, expires_in) end end end end |
#with_client ⇒ Object
38 39 40 41 42 |
# File 'lib/cache_store_redis.rb', line 38 def with_client self.class.pool(@config).with do |client| yield client end end |