Class: Anemone::Storage::Redis
- Inherits:
-
Object
- Object
- Anemone::Storage::Redis
- Defined in:
- lib/anemone/storage/redis.rb
Constant Summary collapse
- MARSHAL_FIELDS =
%w(links visited fetched)
Instance Method Summary collapse
- #[](key) ⇒ Object
- #[]=(key, value) ⇒ Object
- #close ⇒ Object
- #delete(key) ⇒ Object
- #each ⇒ Object
- #has_key?(key) ⇒ Boolean
-
#initialize(opts = {}) ⇒ Redis
constructor
A new instance of Redis.
- #keys ⇒ Object
- #merge!(hash) ⇒ Object
- #size ⇒ Object
Constructor Details
#initialize(opts = {}) ⇒ Redis
Returns a new instance of Redis.
9 10 11 12 13 |
# File 'lib/anemone/storage/redis.rb', line 9 def initialize(opts = {}) @redis = ::Redis.new(opts) @key_prefix = opts[:key_prefix] || 'anemone' keys.each { |key| delete(key) } end |
Instance Method Details
#[](key) ⇒ Object
15 16 17 18 |
# File 'lib/anemone/storage/redis.rb', line 15 def [](key) rkey = "#{@key_prefix}:pages:#{key.to_s}" rget(rkey) end |
#[]=(key, value) ⇒ Object
20 21 22 23 24 25 26 27 28 29 |
# File 'lib/anemone/storage/redis.rb', line 20 def []=(key, value) rkey = "#{@key_prefix}:pages:#{key.to_s}" hash = value.to_hash MARSHAL_FIELDS.each do |field| hash[field] = Marshal.dump(hash[field]) end hash.each do |field, value| @redis.hset(rkey, field, value) end end |
#close ⇒ Object
66 67 68 |
# File 'lib/anemone/storage/redis.rb', line 66 def close @redis.quit end |
#delete(key) ⇒ Object
31 32 33 34 35 36 |
# File 'lib/anemone/storage/redis.rb', line 31 def delete(key) rkey = "#{@key_prefix}:pages:#{key.to_s}" page = self[key] @redis.del(rkey) page end |
#each ⇒ Object
38 39 40 41 42 43 44 |
# File 'lib/anemone/storage/redis.rb', line 38 def each rkeys = @redis.keys("#{@key_prefix}:pages:*") rkeys.each do |rkey| page = rget(rkey) yield page.url.to_s, page end end |
#has_key?(key) ⇒ Boolean
61 62 63 64 |
# File 'lib/anemone/storage/redis.rb', line 61 def has_key?(key) rkey = "#{@key_prefix}:pages:#{key.to_s}" @redis.exists(rkey) end |
#keys ⇒ Object
55 56 57 58 59 |
# File 'lib/anemone/storage/redis.rb', line 55 def keys keys = [] self.each { |k, v| keys << k.to_s } keys end |
#merge!(hash) ⇒ Object
46 47 48 49 |
# File 'lib/anemone/storage/redis.rb', line 46 def merge!(hash) hash.each { |key, value| self[key] = value } self end |
#size ⇒ Object
51 52 53 |
# File 'lib/anemone/storage/redis.rb', line 51 def size @redis.keys("#{@key_prefix}:pages:*").size end |