Module: FreshRedis::Set

Included in:
FreshRedis
Defined in:
lib/fresh_redis/set.rb

Instance Method Summary collapse

Instance Method Details

#fsadd(key, value, options = {}) ⇒ Object 



4
5
6
7
8
9
10
 
# File 'lib/fresh_redis/set.rb', line 4

def fsadd(key, value, options={})
  key = build_key(key, options)
  @redis.multi do
    @redis.sadd(key.redis_key, value)
    @redis.expire(key.redis_key, key.freshness)
  end
end

#fsismembers(key, value, options = {}) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/fresh_redis/set.rb', line 25

def fsismembers(key, value, options={})
  key = build_key(key, options)

  bucket_values = @redis.pipelined {
    key.timestamp_buckets.reverse.each do |bucket_key|
      return true if @redis.sismembers(bucket_key, value)
    end
  }

  # find the first non-nil value
  return false
end

#fsmembers(key, options = {}) ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/fresh_redis/set.rb', line 12

def fsmembers(key, options={})
  key = build_key(key, options)

  bucket_values = @redis.pipelined {
    key.timestamp_buckets.reverse.each do |bucket_key|
      @redis.smembers(bucket_key)
    end
  }

  # find the first non-nil value
  bucket_values.flatten.uniq
end

#fsrem(key, value, options = {}) ⇒ Object 



38
39
40
41
42
43
44
45
46
 
# File 'lib/fresh_redis/set.rb', line 38

def fsrem(key, value, options={})
  key = build_key(key, options)

  bucket_values = @redis.pipelined {
    key.timestamp_buckets.reverse.each do |bucket_key|
      @redis.srem(bucket_key, value)
    end
  }
end