mirror of
https://github.com/dkam/suo.git
synced 2025-01-29 07:42:43 +00:00
Merge pull request #10 from levkk/levkk/support-pooled-clients
Add support for pooled memcached clients by using #with
This commit is contained in:
@@ -7,28 +7,30 @@ module Suo
|
||||
end
|
||||
|
||||
def clear
|
||||
@client.delete(@key)
|
||||
@client.with { |client| client.delete(@key) }
|
||||
end
|
||||
|
||||
private
|
||||
|
||||
def get
|
||||
@client.get_cas(@key)
|
||||
@client.with { |client| client.get_cas(@key) }
|
||||
end
|
||||
|
||||
def set(newval, cas, expire: false)
|
||||
if expire
|
||||
@client.set_cas(@key, newval, cas, @options[:ttl])
|
||||
@client.with { |client| client.set_cas(@key, newval, cas, @options[:ttl]) }
|
||||
else
|
||||
@client.set_cas(@key, newval, cas)
|
||||
@client.with { |client| client.set_cas(@key, newval, cas) }
|
||||
end
|
||||
end
|
||||
|
||||
def initial_set(val = BLANK_STR)
|
||||
@client.set(@key, val)
|
||||
_val, cas = @client.get_cas(@key)
|
||||
@client.with do |client|
|
||||
client.set(@key, val)
|
||||
_val, cas = client.get_cas(@key)
|
||||
cas
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -25,7 +25,7 @@ Gem::Specification.new do |spec|
|
||||
spec.add_dependency "redis"
|
||||
spec.add_dependency "msgpack"
|
||||
|
||||
spec.add_development_dependency "bundler", "~> 1.5"
|
||||
spec.add_development_dependency "bundler"
|
||||
spec.add_development_dependency "rake", "~> 10.0"
|
||||
spec.add_development_dependency "rubocop", "~> 0.49.0"
|
||||
spec.add_development_dependency "minitest", "~> 5.5.0"
|
||||
|
||||
Reference in New Issue
Block a user