Class: Moneta::Adapters::MemcachedNative
- Inherits:
-
Object
- Object
- Moneta::Adapters::MemcachedNative
- Includes:
- Defaults, ExpiresSupport
- Defined in:
- lib/moneta/adapters/memcached/native.rb
Overview
Memcached backend (using gem memcached)
Instance Attribute Summary collapse
- #backend ⇒ Object readonly
Attributes included from ExpiresSupport
Instance Method Summary collapse
-
#clear(options = {}) ⇒ void
Clear all keys in this store.
-
#close ⇒ Object
Explicitly close the store.
-
#create(key, value, options = {}) ⇒ Boolean
Atomically sets a key to value if it’s not set.
-
#delete(key, options = {}) ⇒ Object
Delete the key from the store and return the current value.
-
#increment(key, amount = 1, options = {}) ⇒ Object
Atomically increment integer value with key.
-
#initialize(options = {}) ⇒ MemcachedNative
constructor
A new instance of MemcachedNative.
-
#load(key, options = {}) ⇒ Object
Fetch value with key.
-
#store(key, value, options = {}) ⇒ Object
Store value with key.
Methods included from ExpiresSupport
Methods included from Defaults
#[], #[]=, #decrement, #each_key, #features, #fetch, #fetch_values, included, #key?, #merge!, #slice, #supports?, #update, #values_at
Methods included from OptionSupport
#expires, #prefix, #raw, #with
Constructor Details
#initialize(options = {}) ⇒ MemcachedNative
Returns a new instance of MemcachedNative.
20 21 22 23 24 25 26 27 28 29 30 31 |
# File 'lib/moneta/adapters/memcached/native.rb', line 20 def initialize( = {}) server = .delete(:server) || '127.0.0.1:11211' self.default_expires = .delete(:expires) @backend = [:backend] || begin [:prefix_key] = .delete(:namespace) if [:namespace] # We don't want a limitation on the key charset. Therefore we use the binary protocol. # It is also faster. [:binary_protocol] = true unless .include?(:binary_protocol) ::Memcached.new(server, ) end end |
Instance Attribute Details
#backend ⇒ Object (readonly)
12 13 14 |
# File 'lib/moneta/adapters/memcached/native.rb', line 12 def backend @backend end |
Instance Method Details
#clear(options = {}) ⇒ void
This method returns an undefined value.
Clear all keys in this store
93 94 95 96 |
# File 'lib/moneta/adapters/memcached/native.rb', line 93 def clear( = {}) @backend.flush self end |
#close ⇒ Object
Explicitly close the store
99 100 101 102 |
# File 'lib/moneta/adapters/memcached/native.rb', line 99 def close @backend.reset nil end |
#create(key, value, options = {}) ⇒ Boolean
Not every Moneta store implements this method, a NotImplementedError is raised if it is not supported.
Atomically sets a key to value if it’s not set.
83 84 85 86 87 88 89 90 |
# File 'lib/moneta/adapters/memcached/native.rb', line 83 def create(key, value, = {}) expires = expires_value() Numeric === expires and expires = expires.to_i @backend.add(key, value, expires || 0, false) true rescue ::Memcached::ConnectionDataExists false end |
#delete(key, options = {}) ⇒ Object
Delete the key from the store and return the current value
58 59 60 61 62 63 64 |
# File 'lib/moneta/adapters/memcached/native.rb', line 58 def delete(key, = {}) value = @backend.get(key, false) @backend.delete(key) value rescue ::Memcached::NotFound nil end |
#increment(key, amount = 1, options = {}) ⇒ Object
Not every Moneta store implements this method, a NotImplementedError is raised if it is not supported.
Atomically increment integer value with key
This method also accepts negative amounts.
67 68 69 70 71 72 73 74 75 76 77 78 79 80 |
# File 'lib/moneta/adapters/memcached/native.rb', line 67 def increment(key, amount = 1, = {}) result = if amount >= 0 @backend.increment(key, amount) else @backend.decrement(key, -amount) end # HACK: Throw error if applied to invalid value # see https://github.com/evan/memcached/issues/110 Integer((@backend.get(key, false) rescue 0)) if result == 0 result rescue ::Memcached::NotFound retry unless create(key, amount.to_s, ) amount end |
#load(key, options = {}) ⇒ Object
Fetch value with key. Return nil if the key doesn’t exist
34 35 36 37 38 39 40 41 42 43 44 45 46 |
# File 'lib/moneta/adapters/memcached/native.rb', line 34 def load(key, = {}) value = @backend.get(key, false) if value expires = expires_value(, nil) unless expires == nil Numeric === expires and expires = expires.to_i @backend.set(key, value, expires || 0, false) end value end rescue ::Memcached::NotFound nil end |
#store(key, value, options = {}) ⇒ Object
Store value with key
49 50 51 52 53 54 55 |
# File 'lib/moneta/adapters/memcached/native.rb', line 49 def store(key, value, = {}) # TTL must be Integer expires = expires_value() Numeric === expires and expires = expires.to_i @backend.set(key, value, expires || 0, false) value end |