Class: SplitIoClient::Cache::Adapters::RedisAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/splitclient-rb/cache/adapters/redis_adapter.rb

Overview

Redis adapter used to provide interface to Redis

Constant Summary collapse

SCAN_SLICE = 
5000

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(redis_url) ⇒ RedisAdapter

Returns a new instance of RedisAdapter.



12
13
14
15
16
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 12

def initialize(redis_url)
  connection = redis_url.is_a?(Hash) ? redis_url : { url: redis_url }

  @redis = Redis.new(connection)
end

Instance Attribute Details

#redis ⇒ Object (readonly)

Returns the value of attribute redis.



10
11
12
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 10

def redis
  @redis
end

Instance Method Details

#add_to_map(key, field, value) ⇒ Object 



23
24
25
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 23

def add_to_map(key, field, value)
  @redis.hset(key, field, value)
end

#add_to_queue(key, val) ⇒ Object

Queue



122
123
124
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 122

def add_to_queue(key, val)
  @redis.rpush(key, val)
end

#add_to_set(key, val) ⇒ Object 



91
92
93
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 91

def add_to_set(key, val)
  @redis.sadd(key, val)
end

#append_to_string(key, val) ⇒ Object 



74
75
76
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 74

def append_to_string(key, val)
  @redis.append(key, val)
end

#bool(key) ⇒ Object 



83
84
85
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 83

def bool(key)
  @redis.get(key) == 'true'
end

#clear(prefix) ⇒ Object 



157
158
159
160
161
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 157

def clear(prefix)
  keys = @redis.keys("#{prefix}*")

  keys.map { |key| @redis.del(key) }
end

#delete(key) ⇒ Object 



141
142
143
144
145
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 141

def delete(key)
  return nil if key == []

  @redis.del(key)
end

#delete_from_map(key, field) ⇒ Object 



31
32
33
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 31

def delete_from_map(key, field)
  @redis.hdel(key, field)
end

#delete_from_set(key, val) ⇒ Object 



95
96
97
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 95

def delete_from_set(key, val)
  @redis.srem(key, val)
end

#exists?(key) ⇒ Boolean

General

Returns:

  • (Boolean) 


137
138
139
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 137

def exists?(key)
  @redis.exists(key)
end

#find_in_map(key, field) ⇒ Object 



27
28
29
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 27

def find_in_map(key, field)
  @redis.hget(key, field)
end

#find_strings_by_prefix(prefix) ⇒ Object Also known as: find_sets_by_prefix 



56
57
58
59
60
61
62
63
64
65
66
67
68
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 56

def find_strings_by_prefix(prefix)
  memo = { items: [], cursor: 0 }

  loop do
    memo[:cursor], items = @redis.scan(memo[:cursor], match: "#{prefix}*", count: SCAN_SLICE)

    memo[:items].push(*items)

    break if memo[:cursor] == '0'
  end

  memo[:items]
end

#get_all_from_set(key) ⇒ Object 



107
108
109
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 107

def get_all_from_set(key)
  @redis.smembers(key)
end

#get_from_queue(key, count) ⇒ Object 



126
127
128
129
130
131
132
133
134
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 126

def get_from_queue(key, count)
  items = @redis.lrange(key, 0, count - 1)
  fetched_count = items.size
  items_to_remove = (fetched_count == count) ? count : fetched_count

  @redis.ltrim(key, items_to_remove, -1)

  items
end

#get_map(key) ⇒ Object 



43
44
45
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 43

def get_map(key)
  @redis.hgetall(key)
end

#get_set(key) ⇒ Object 



99
100
101
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 99

def get_set(key)
  @redis.smembers(key)
end

#in_map?(key, field) ⇒ Boolean

Returns:

  • (Boolean) 


35
36
37
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 35

def in_map?(key, field)
  @redis.hexists(key, field)
end

#in_set?(key, val) ⇒ Boolean

Returns:

  • (Boolean) 


103
104
105
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 103

def in_set?(key, val)
  @redis.sismember(key, val)
end

#inc(key, inc = 1) ⇒ Object 



147
148
149
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 147

def inc(key, inc = 1)
  @redis.incrby(key, inc)
end

#initialize_map(key) ⇒ Object Also known as: initialize_set

Map



19
20
21
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 19

def initialize_map(key)
  # No need to initialize hash/map in Redis
end

#map_keys(key) ⇒ Object 



39
40
41
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 39

def map_keys(key)
  @redis.hkeys(key)
end

#multiple_strings(keys) ⇒ Object 



70
71
72
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 70

def multiple_strings(keys)
  Hash[keys.zip(@redis.mget(keys))]
end

#pipelined(&block) ⇒ Object 



151
152
153
154
155
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 151

def pipelined(&block)
  @redis.pipelined do
    block.call
  end
end

#random_set_elements(key, count) ⇒ Object 



117
118
119
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 117

def random_set_elements(key, count)
  @redis.srandmember(key, count)
end

#set_bool(key, val) ⇒ Object

Bool



79
80
81
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 79

def set_bool(key, val)
  @redis.set(key, val.to_s)
end

#set_string(key, str) ⇒ Object 



52
53
54
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 52

def set_string(key, str)
  @redis.set(key, str)
end

#string(key) ⇒ Object

String



48
49
50
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 48

def string(key)
  @redis.get(key)
end

#union_sets(set_keys) ⇒ Object 



111
112
113
114
115
 
# File 'lib/splitclient-rb/cache/adapters/redis_adapter.rb', line 111

def union_sets(set_keys)
  return [] if set_keys == []

  @redis.sunion(set_keys)
end