Sha256: 27147633adf9d1a920a7b0389781fb3552b8ff61e8c62ac581c2dcc5324e8ba5
Contents?: true
Size: 1.27 KB
Versions: 14
Compression:
Stored size: 1.27 KB
Contents
class Memcache
class LocalServer < Base
def initialize
@data = {}
@expiry = {}
end
def name
"local:#{hash}"
end
def stats
{ # curr_items may include items that have expired.
'curr_items' => @data.size,
'expiry_count' => @expiry.size,
}
end
def flush_all(delay = 0)
raise 'flush_all not supported with delay' if delay != 0
@data.clear
@expiry.clear
end
def get(keys, cas = false)
if keys.kind_of?(Array)
hash = {}
keys.each do |key|
key = key.to_s
val = get(key)
hash[key] = val if val
end
hash
else
key = cache_key(keys)
if @expiry[key] and Time.now > @expiry[key]
@data[key] = nil
@expiry[key] = nil
end
@data[key]
end
end
def set(key, value, expiry = 0, flags = 0)
key = cache_key(key)
@data[key] = value.to_s
expiry = Time.at(expiry) if expiry > 60*60*24*30
if expiry.kind_of?(Time)
@expiry[key] = expiry
else
expiry = expiry.to_i
@expiry[key] = expiry == 0 ? nil : Time.now + expiry
end
value
end
def delete(key)
@data.delete(cache_key(key)) && true
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems