Class: Redis::Distributed

Inherits:
Object
  • Object
show all
Defined in:
lib/redis/distributed.rb

Defined Under Namespace

Classes: CannotDistribute

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(urls, options = {}) ⇒ Distributed

Returns a new instance of Distributed.



18
19
20
21
22
23
 
# File 'lib/redis/distributed.rb', line 18

def initialize(urls, options = {})
  @tag = options.delete(:tag) || /^\{(.+?)\}/
  @default_options = options
  @ring = HashRing.new urls.map { |url| Redis.connect(options.merge(:url => url)) }
  @subscribed_node = nil
end

Instance Attribute Details

#ring ⇒ Object (readonly)

Returns the value of attribute ring.



16
17
18
 
# File 'lib/redis/distributed.rb', line 16

def ring
  @ring
end

Instance Method Details

#[](key) ⇒ Object 



174
175
176
 
# File 'lib/redis/distributed.rb', line 174

def [](key)
  get(key)
end

#[]=(key, value) ⇒ Object 



183
184
185
 
# File 'lib/redis/distributed.rb', line 183

def []=(key,value)
  set(key, value)
end

#add_node(url) ⇒ Object 



33
34
35
 
# File 'lib/redis/distributed.rb', line 33

def add_node(url)
  @ring.add_node Redis.connect(@default_options.merge(:url => url))
end

#append(key, value) ⇒ Object

Append a value to a key.



179
180
181
 
# File 'lib/redis/distributed.rb', line 179

def append(key, value)
  node_for(key).append(key, value)
end

#bgsave ⇒ Object

Asynchronously save the dataset to disk.



637
638
639
 
# File 'lib/redis/distributed.rb', line 637

def bgsave
  on_each_node :bgsave
end

#blpop(key, timeout) ⇒ Object

Remove and get the first element in a list, or block until one is available.



299
300
301
 
# File 'lib/redis/distributed.rb', line 299

def blpop(key, timeout)
  node_for(key).blpop(key, timeout)
end

#brpop(key, timeout) ⇒ Object

Remove and get the last element in a list, or block until one is available.



305
306
307
 
# File 'lib/redis/distributed.rb', line 305

def brpop(key, timeout)
  node_for(key).brpop(key, timeout)
end

#brpoplpush(source, destination, timeout) ⇒ Object

Pop a value from a list, push it to another list and return it; or block until one is available.



311
312
313
314
315
 
# File 'lib/redis/distributed.rb', line 311

def brpoplpush(source, destination, timeout)
  ensure_same_node(:brpoplpush, source, destination) do |node|
    node.brpoplpush(source, destination, timeout)
  end
end

#dbsize ⇒ Object

Return the number of keys in the selected database.



100
101
102
 
# File 'lib/redis/distributed.rb', line 100

def dbsize
  on_each_node :dbsize
end

#decr(key) ⇒ Object

Decrement the integer value of a key by one.



230
231
232
 
# File 'lib/redis/distributed.rb', line 230

def decr(key)
  node_for(key).decr(key)
end

#decrby(key, decrement) ⇒ Object

Decrement the integer value of a key by the given number.



235
236
237
 
# File 'lib/redis/distributed.rb', line 235

def decrby(key, decrement)
  node_for(key).decrby(key, decrement)
end

#del(*args) ⇒ Object

Delete a key.



63
64
65
66
67
68
 
# File 'lib/redis/distributed.rb', line 63

def del(*args)
  keys_per_node = args.group_by { |key| node_for(key) }
  keys_per_node.inject(0) do |sum, (node, keys)|
    sum + node.del(*keys)
  end
end

#discard ⇒ Object

Discard all commands issued after MULTI.

Raises:



588
589
590
 
# File 'lib/redis/distributed.rb', line 588

def discard
  raise CannotDistribute, :discard
end

#echo(value) ⇒ Object

Echo the given string.



657
658
659
 
# File 'lib/redis/distributed.rb', line 657

def echo(value)
  on_each_node :echo, value
end

#exec ⇒ Object

Execute all commands issued after MULTI.

Raises:



583
584
585
 
# File 'lib/redis/distributed.rb', line 583

def exec
  raise CannotDistribute, :exec
end

#exists(key) ⇒ Object

Determine if a key exists.



58
59
60
 
# File 'lib/redis/distributed.rb', line 58

def exists(key)
  node_for(key).exists(key)
end

#expire(key, seconds) ⇒ Object

Set a key’s time to live in seconds.



105
106
107
 
# File 'lib/redis/distributed.rb', line 105

def expire(key, seconds)
  node_for(key).expire(key, seconds)
end

#expireat(key, unix_time) ⇒ Object

Set the expiration for a key as a UNIX timestamp.



110
111
112
 
# File 'lib/redis/distributed.rb', line 110

def expireat(key, unix_time)
  node_for(key).expireat(key, unix_time)
end

#flushall ⇒ Object

Remove all keys from all databases.



53
54
55
 
# File 'lib/redis/distributed.rb', line 53

def flushall
  on_each_node :flushall
end

#flushdb ⇒ Object

Remove all keys from the current database.



130
131
132
 
# File 'lib/redis/distributed.rb', line 130

def flushdb
  on_each_node :flushdb
end

#get(key) ⇒ Object

Get the value of a key.



155
156
157
 
# File 'lib/redis/distributed.rb', line 155

def get(key)
  node_for(key).get(key)
end

#getbit(key, offset) ⇒ Object

Returns the bit value at offset in the string value stored at key.



160
161
162
 
# File 'lib/redis/distributed.rb', line 160

def getbit(key, offset)
  node_for(key).getbit(key, offset)
end

#getrange(key, start, stop) ⇒ Object

Get a substring of the string stored at a key.



165
166
167
 
# File 'lib/redis/distributed.rb', line 165

def getrange(key, start, stop)
  node_for(key).getrange(key, start, stop)
end

#getset(key, value) ⇒ Object

Set the string value of a key and return its old value.



170
171
172
 
# File 'lib/redis/distributed.rb', line 170

def getset(key, value)
  node_for(key).getset(key, value)
end

#hdel(key, field) ⇒ Object

Delete one or more hash fields.



506
507
508
 
# File 'lib/redis/distributed.rb', line 506

def hdel(key, field)
  node_for(key).hdel(key, field)
end

#hexists(key, field) ⇒ Object

Determine if a hash field exists.



511
512
513
 
# File 'lib/redis/distributed.rb', line 511

def hexists(key, field)
  node_for(key).hexists(key, field)
end

#hget(key, field) ⇒ Object

Get the value of a hash field.



501
502
503
 
# File 'lib/redis/distributed.rb', line 501

def hget(key, field)
  node_for(key).hget(key, field)
end

#hgetall(key) ⇒ Object

Get all the fields and values in a hash.



531
532
533
 
# File 'lib/redis/distributed.rb', line 531

def hgetall(key)
  node_for(key).hgetall(key)
end

#hincrby(key, field, increment) ⇒ Object

Increment the integer value of a hash field by the given number.



554
555
556
 
# File 'lib/redis/distributed.rb', line 554

def hincrby(key, field, increment)
  node_for(key).hincrby(key, field, increment)
end

#hkeys(key) ⇒ Object

Get all the fields in a hash.



521
522
523
 
# File 'lib/redis/distributed.rb', line 521

def hkeys(key)
  node_for(key).hkeys(key)
end

#hlen(key) ⇒ Object

Get the number of fields in a hash.



516
517
518
 
# File 'lib/redis/distributed.rb', line 516

def hlen(key)
  node_for(key).hlen(key)
end

#hmget(key, *fields) ⇒ Object

Get the values of all the given hash fields.



545
546
547
 
# File 'lib/redis/distributed.rb', line 545

def hmget(key, *fields)
  node_for(key).hmget(key, *fields)
end

#hmset(key, *attrs) ⇒ Object

Set multiple hash fields to multiple values.



536
537
538
 
# File 'lib/redis/distributed.rb', line 536

def hmset(key, *attrs)
  node_for(key).hmset(key, *attrs)
end

#hset(key, field, value) ⇒ Object

Set the string value of a hash field.



491
492
493
 
# File 'lib/redis/distributed.rb', line 491

def hset(key, field, value)
  node_for(key).hset(key, field, value)
end

#hsetnx(key, field, value) ⇒ Object

Set the value of a hash field, only if the field does not exist.



496
497
498
 
# File 'lib/redis/distributed.rb', line 496

def hsetnx(key, field, value)
  node_for(key).hsetnx(key, field, value)
end

#hvals(key) ⇒ Object

Get all the values in a hash.



526
527
528
 
# File 'lib/redis/distributed.rb', line 526

def hvals(key)
  node_for(key).hvals(key)
end

#incr(key) ⇒ Object

Increment the integer value of a key by one.



220
221
222
 
# File 'lib/redis/distributed.rb', line 220

def incr(key)
  node_for(key).incr(key)
end

#incrby(key, increment) ⇒ Object

Increment the integer value of a key by the given number.



225
226
227
 
# File 'lib/redis/distributed.rb', line 225

def incrby(key, increment)
  node_for(key).incrby(key, increment)
end

#info(cmd = nil) ⇒ Object

Get information and statistics about the server.



647
648
649
 
# File 'lib/redis/distributed.rb', line 647

def info(cmd = nil)
  on_each_node :info, cmd
end

#inspect ⇒ Object 



665
666
667
668
669
670
 
# File 'lib/redis/distributed.rb', line 665

def inspect
  node_info = nodes.map do |node|
    "#{node.id} (Redis v#{node.info['redis_version']})"
  end
  "#<Redis client v#{Redis::VERSION} connected to #{node_info.join(', ')}>"
end

#keys(glob = "*") ⇒ Object

Find all keys matching the given pattern.



76
77
78
 
# File 'lib/redis/distributed.rb', line 76

def keys(glob = "*")
  on_each_node(:keys, glob).flatten
end

#lastsave ⇒ Object

Get the UNIX time stamp of the last successful save to disk.



642
643
644
 
# File 'lib/redis/distributed.rb', line 642

def lastsave
  on_each_node :lastsave
end

#lindex(key, index) ⇒ Object

Get an element from a list by its index.



265
266
267
 
# File 'lib/redis/distributed.rb', line 265

def lindex(key, index)
  node_for(key).lindex(key, index)
end

#llen(key) ⇒ Object

Get the length of a list.



250
251
252
 
# File 'lib/redis/distributed.rb', line 250

def llen(key)
  node_for(key).llen(key)
end

#lpop(key) ⇒ Object

Remove and get the first element in a list.



280
281
282
 
# File 'lib/redis/distributed.rb', line 280

def lpop(key)
  node_for(key).lpop(key)
end

#lpush(key, value) ⇒ Object

Prepend one or more values to a list.



245
246
247
 
# File 'lib/redis/distributed.rb', line 245

def lpush(key, value)
  node_for(key).lpush(key, value)
end

#lrange(key, start, stop) ⇒ Object

Get a range of elements from a list.



255
256
257
 
# File 'lib/redis/distributed.rb', line 255

def lrange(key, start, stop)
  node_for(key).lrange(key, start, stop)
end

#lrem(key, count, value) ⇒ Object

Remove elements from a list.



275
276
277
 
# File 'lib/redis/distributed.rb', line 275

def lrem(key, count, value)
  node_for(key).lrem(key, count, value)
end

#lset(key, index, value) ⇒ Object

Set the value of an element in a list by its index.



270
271
272
 
# File 'lib/redis/distributed.rb', line 270

def lset(key, index, value)
  node_for(key).lset(key, index, value)
end

#ltrim(key, start, stop) ⇒ Object

Trim a list to the specified range.



260
261
262
 
# File 'lib/redis/distributed.rb', line 260

def ltrim(key, start, stop)
  node_for(key).ltrim(key, start, stop)
end

#mapped_hmget(key, *fields) ⇒ Object 



549
550
551
 
# File 'lib/redis/distributed.rb', line 549

def mapped_hmget(key, *fields)
  Hash[*fields.zip(hmget(key, *fields)).flatten]
end

#mapped_hmset(key, hash) ⇒ Object 



540
541
542
 
# File 'lib/redis/distributed.rb', line 540

def mapped_hmset(key, hash)
  node_for(key).hmset(key, *hash.to_a.flatten)
end

#mapped_mget(*keys) ⇒ Object

Raises:



192
193
194
 
# File 'lib/redis/distributed.rb', line 192

def mapped_mget(*keys)
  raise CannotDistribute, :mapped_mget
end

#mapped_mset(hash) ⇒ Object

Raises:



206
207
208
 
# File 'lib/redis/distributed.rb', line 206

def mapped_mset(hash)
  raise CannotDistribute, :mapped_mset
end

#mapped_msetnx(hash) ⇒ Object

Raises:



215
216
217
 
# File 'lib/redis/distributed.rb', line 215

def mapped_msetnx(hash)
  raise CannotDistribute, :mapped_msetnx
end

#mget(*keys) ⇒ Object

Get the values of all the given keys.

Raises:



188
189
190
 
# File 'lib/redis/distributed.rb', line 188

def mget(*keys)
  raise CannotDistribute, :mget
end

#monitor ⇒ Object

Listen for all requests received by the server in real time.

Raises:

  • (NotImplementedError) 


652
653
654
 
# File 'lib/redis/distributed.rb', line 652

def monitor
  raise NotImplementedError
end

#move(key, db) ⇒ Object

Move a key to another database.



125
126
127
 
# File 'lib/redis/distributed.rb', line 125

def move(key, db)
  node_for(key).move(key, db)
end

#mset(*args) ⇒ Object

Set multiple keys to multiple values.

Raises:



202
203
204
 
# File 'lib/redis/distributed.rb', line 202

def mset(*args)
  raise CannotDistribute, :mset
end

#msetnx(*args) ⇒ Object

Set multiple keys to multiple values, only if none of the keys exist.

Raises:



211
212
213
 
# File 'lib/redis/distributed.rb', line 211

def msetnx(*args)
  raise CannotDistribute, :msetnx
end

#multi ⇒ Object

Mark the start of a transaction block.

Raises:



568
569
570
 
# File 'lib/redis/distributed.rb', line 568

def multi
  raise CannotDistribute, :multi
end

#node_for(key) ⇒ Object 



25
26
27
 
# File 'lib/redis/distributed.rb', line 25

def node_for(key)
  @ring.get_node(key_tag(key.to_s) || key.to_s)
end

#nodes ⇒ Object 



29
30
31
 
# File 'lib/redis/distributed.rb', line 29

def nodes
  @ring.nodes
end

#persist(key) ⇒ Object

Remove the expiration from a key.



115
116
117
 
# File 'lib/redis/distributed.rb', line 115

def persist(key)
  node_for(key).persist(key)
end

#ping ⇒ Object

Ping the server.



48
49
50
 
# File 'lib/redis/distributed.rb', line 48

def ping
  on_each_node :ping
end

#pipelined ⇒ Object

Raises:



661
662
663
 
# File 'lib/redis/distributed.rb', line 661

def pipelined
  raise CannotDistribute, :pipelined
end

#psubscribe(*channels, &block) ⇒ Object

Listen for messages published to channels matching the given patterns.

Raises:

  • (NotImplementedError) 


627
628
629
 
# File 'lib/redis/distributed.rb', line 627

def psubscribe(*channels, &block)
  raise NotImplementedError
end

#publish(channel, message) ⇒ Object

Post a message to a channel.



593
594
595
 
# File 'lib/redis/distributed.rb', line 593

def publish(channel, message)
  node_for(channel).publish(channel, message)
end

#punsubscribe(*channels) ⇒ Object

Stop listening for messages posted to channels matching the given patterns.

Raises:

  • (NotImplementedError) 


622
623
624
 
# File 'lib/redis/distributed.rb', line 622

def punsubscribe(*channels)
  raise NotImplementedError
end

#quit ⇒ Object

Close the connection.



38
39
40
 
# File 'lib/redis/distributed.rb', line 38

def quit
  on_each_node :quit
end

#randomkey ⇒ Object

Return a random key from the keyspace.

Raises:



81
82
83
 
# File 'lib/redis/distributed.rb', line 81

def randomkey
  raise CannotDistribute, :randomkey
end

#rename(old_name, new_name) ⇒ Object

Rename a key.



86
87
88
89
90
 
# File 'lib/redis/distributed.rb', line 86

def rename(old_name, new_name)
  ensure_same_node(:rename, old_name, new_name) do |node|
    node.rename(old_name, new_name)
  end
end

#renamenx(old_name, new_name) ⇒ Object

Rename a key, only if the new key does not exist.



93
94
95
96
97
 
# File 'lib/redis/distributed.rb', line 93

def renamenx(old_name, new_name)
  ensure_same_node(:renamenx, old_name, new_name) do |node|
    node.renamenx(old_name, new_name)
  end
end

#rpop(key) ⇒ Object

Remove and get the last element in a list.



285
286
287
 
# File 'lib/redis/distributed.rb', line 285

def rpop(key)
  node_for(key).rpop(key)
end

#rpoplpush(source, destination) ⇒ Object

Remove the last element in a list, append it to another list and return it.



291
292
293
294
295
 
# File 'lib/redis/distributed.rb', line 291

def rpoplpush(source, destination)
  ensure_same_node(:rpoplpush, source, destination) do |node|
    node.rpoplpush(source, destination)
  end
end

#rpush(key, value) ⇒ Object

Append one or more values to a list.



240
241
242
 
# File 'lib/redis/distributed.rb', line 240

def rpush(key, value)
  node_for(key).rpush(key, value)
end

#sadd(key, member) ⇒ Object

Add one or more members to a set.



318
319
320
 
# File 'lib/redis/distributed.rb', line 318

def sadd(key, member)
  node_for(key).sadd(key, member)
end

#save ⇒ Object

Synchronously save the dataset to disk.



632
633
634
 
# File 'lib/redis/distributed.rb', line 632

def save
  on_each_node :save
end

#scard(key) ⇒ Object

Get the number of members in a set.



340
341
342
 
# File 'lib/redis/distributed.rb', line 340

def scard(key)
  node_for(key).scard(key)
end

#sdiff(*keys) ⇒ Object

Subtract multiple sets.



378
379
380
381
382
 
# File 'lib/redis/distributed.rb', line 378

def sdiff(*keys)
  ensure_same_node(:sdiff, *keys) do |node|
    node.sdiff(*keys)
  end
end

#sdiffstore(destination, *keys) ⇒ Object

Subtract multiple sets and store the resulting set in a key.



385
386
387
388
389
 
# File 'lib/redis/distributed.rb', line 385

def sdiffstore(destination, *keys)
  ensure_same_node(:sdiffstore, destination, *keys) do |node|
    node.sdiffstore(destination, *keys)
  end
end

#select(db) ⇒ Object

Change the selected database for the current connection.



43
44
45
 
# File 'lib/redis/distributed.rb', line 43

def select(db)
  on_each_node :select, db
end

#set(key, value) ⇒ Object

Set the string value of a key.



135
136
137
 
# File 'lib/redis/distributed.rb', line 135

def set(key, value)
  node_for(key).set(key, value)
end

#setbit(key, offset, value) ⇒ Object

Sets or clears the bit at offset in the string value stored at key.



140
141
142
 
# File 'lib/redis/distributed.rb', line 140

def setbit(key, offset, value)
  node_for(key).setbit(key, offset, value)
end

#setex(key, ttl, value) ⇒ Object

Set the value and expiration of a key.



150
151
152
 
# File 'lib/redis/distributed.rb', line 150

def setex(key, ttl, value)
  node_for(key).setex(key, ttl, value)
end

#setnx(key, value) ⇒ Object

Set the value of a key, only if the key does not exist.



197
198
199
 
# File 'lib/redis/distributed.rb', line 197

def setnx(key, value)
  node_for(key).setnx(key, value)
end

#setrange(key, offset, value) ⇒ Object

Overwrite part of a string at key starting at the specified offset.



145
146
147
 
# File 'lib/redis/distributed.rb', line 145

def setrange(key, offset, value)
  node_for(key).setrange(key, offset, value)
end

#sinter(*keys) ⇒ Object

Intersect multiple sets.



350
351
352
353
354
 
# File 'lib/redis/distributed.rb', line 350

def sinter(*keys)
  ensure_same_node(:sinter, *keys) do |node|
    node.sinter(*keys)
  end
end

#sinterstore(destination, *keys) ⇒ Object

Intersect multiple sets and store the resulting set in a key.



357
358
359
360
361
 
# File 'lib/redis/distributed.rb', line 357

def sinterstore(destination, *keys)
  ensure_same_node(:sinterstore, destination, *keys) do |node|
    node.sinterstore(destination, *keys)
  end
end

#sismember(key, member) ⇒ Object

Determine if a given value is a member of a set.



345
346
347
 
# File 'lib/redis/distributed.rb', line 345

def sismember(key, member)
  node_for(key).sismember(key, member)
end

#smembers(key) ⇒ Object

Get all the members in a set.



392
393
394
 
# File 'lib/redis/distributed.rb', line 392

def smembers(key)
  node_for(key).smembers(key)
end

#smove(source, destination, member) ⇒ Object

Move a member from one set to another.



333
334
335
336
337
 
# File 'lib/redis/distributed.rb', line 333

def smove(source, destination, member)
  ensure_same_node(:smove, source, destination) do |node|
    node.smove(source, destination, member)
  end
end

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

Sort the elements in a list, set or sorted set.



559
560
561
562
563
564
565
 
# File 'lib/redis/distributed.rb', line 559

def sort(key, options = {})
  keys = [key, options[:by], options[:store], *Array(options[:get])].compact

  ensure_same_node(:sort, *keys) do |node|
    node.sort(key, options)
  end
end

#spop(key) ⇒ Object

Remove and return a random member from a set.



328
329
330
 
# File 'lib/redis/distributed.rb', line 328

def spop(key)
  node_for(key).spop(key)
end

#srandmember(key) ⇒ Object

Get a random member from a set.



397
398
399
 
# File 'lib/redis/distributed.rb', line 397

def srandmember(key)
  node_for(key).srandmember(key)
end

#srem(key, member) ⇒ Object

Remove one or more members from a set.



323
324
325
 
# File 'lib/redis/distributed.rb', line 323

def srem(key, member)
  node_for(key).srem(key, member)
end

#subscribe(channel, *channels, &block) ⇒ Object

Listen for messages published to the given channels.



608
609
610
611
612
613
614
615
616
617
618
 
# File 'lib/redis/distributed.rb', line 608

def subscribe(channel, *channels, &block)
  if channels.empty?
    @subscribed_node = node_for(channel)
    @subscribed_node.subscribe(channel, &block)
  else
    ensure_same_node(:subscribe, channel, *channels) do |node|
      @subscribed_node = node
      node.subscribe(channel, *channels, &block)
    end
  end
end

#subscribed? ⇒ Boolean

Returns:

  • (Boolean) 


597
598
599
 
# File 'lib/redis/distributed.rb', line 597

def subscribed?
  !! @subscribed_node
end

#sunion(*keys) ⇒ Object

Add multiple sets.



364
365
366
367
368
 
# File 'lib/redis/distributed.rb', line 364

def sunion(*keys)
  ensure_same_node(:sunion, *keys) do |node|
    node.sunion(*keys)
  end
end

#sunionstore(destination, *keys) ⇒ Object

Add multiple sets and store the resulting set in a key.



371
372
373
374
375
 
# File 'lib/redis/distributed.rb', line 371

def sunionstore(destination, *keys)
  ensure_same_node(:sunionstore, destination, *keys) do |node|
    node.sunionstore(destination, *keys)
  end
end

#ttl(key) ⇒ Object

Get the time to live for a key.



120
121
122
 
# File 'lib/redis/distributed.rb', line 120

def ttl(key)
  node_for(key).ttl(key)
end

#type(key) ⇒ Object

Determine the type stored at key.



71
72
73
 
# File 'lib/redis/distributed.rb', line 71

def type(key)
  node_for(key).type(key)
end

#unsubscribe(*channels) ⇒ Object

Stop listening for messages posted to the given channels.

Raises:

  • (RuntimeError) 


602
603
604
605
 
# File 'lib/redis/distributed.rb', line 602

def unsubscribe(*channels)
  raise RuntimeError, "Can't unsubscribe if not subscribed." unless subscribed?
  @subscribed_node.unsubscribe(*channels)
end

#unwatch ⇒ Object

Forget about all watched keys.

Raises:



578
579
580
 
# File 'lib/redis/distributed.rb', line 578

def unwatch
  raise CannotDistribute, :unwatch
end

#watch(*keys) ⇒ Object

Watch the given keys to determine execution of the MULTI/EXEC block.

Raises:



573
574
575
 
# File 'lib/redis/distributed.rb', line 573

def watch(*keys)
  raise CannotDistribute, :watch
end

#zadd(key, *args) ⇒ Object

Add one or more members to a sorted set, or update the score for members that already exist.



403
404
405
 
# File 'lib/redis/distributed.rb', line 403

def zadd(key, *args)
  node_for(key).zadd(key, *args)
end

#zcard(key) ⇒ Object

Get the number of members in a sorted set.



461
462
463
 
# File 'lib/redis/distributed.rb', line 461

def zcard(key)
  node_for(key).zcard(key)
end

#zcount(key, min, max) ⇒ Object

Get the number of members in a particular score range.



466
467
468
 
# File 'lib/redis/distributed.rb', line 466

def zcount(key, min, max)
  node_for(key).zcount(key, min, max)
end

#zincrby(key, increment, member) ⇒ Object

Increment the score of a member in a sorted set.



413
414
415
 
# File 'lib/redis/distributed.rb', line 413

def zincrby(key, increment, member)
  node_for(key).zincrby(key, increment, member)
end

#zinterstore(destination, keys, options = {}) ⇒ Object

Intersect multiple sorted sets and store the resulting sorted set in a new key.



477
478
479
480
481
 
# File 'lib/redis/distributed.rb', line 477

def zinterstore(destination, keys, options = {})
  ensure_same_node(:zinterstore, destination, *keys) do |node|
    node.zinterstore(destination, keys, options)
  end
end

#zrange(key, start, stop, options = {}) ⇒ Object

Return a range of members in a sorted set, by index.



418
419
420
 
# File 'lib/redis/distributed.rb', line 418

def zrange(key, start, stop, options = {})
  node_for(key).zrange(key, start, stop, options)
end

#zrangebyscore(key, min, max, options = {}) ⇒ Object

Return a range of members in a sorted set, by score.



450
451
452
 
# File 'lib/redis/distributed.rb', line 450

def zrangebyscore(key, min, max, options = {})
  node_for(key).zrangebyscore(key, min, max, options)
end

#zrank(key, member) ⇒ Object

Determine the index of a member in a sorted set.



423
424
425
 
# File 'lib/redis/distributed.rb', line 423

def zrank(key, member)
  node_for(key).zrank(key, member)
end

#zrem(key, member) ⇒ Object

Remove one or more members from a sorted set.



408
409
410
 
# File 'lib/redis/distributed.rb', line 408

def zrem(key, member)
  node_for(key).zrem(key, member)
end

#zremrangebyrank(key, start, stop) ⇒ Object

Remove all members in a sorted set within the given indexes.



445
446
447
 
# File 'lib/redis/distributed.rb', line 445

def zremrangebyrank(key, start, stop)
  node_for(key).zremrangebyrank(key, start, stop)
end

#zremrangebyscore(key, min, max) ⇒ Object

Remove all members in a sorted set within the given scores.



440
441
442
 
# File 'lib/redis/distributed.rb', line 440

def zremrangebyscore(key, min, max)
  node_for(key).zremrangebyscore(key, min, max)
end

#zrevrange(key, start, stop, options = {}) ⇒ Object

Return a range of members in a sorted set, by index, with scores ordered from high to low.



435
436
437
 
# File 'lib/redis/distributed.rb', line 435

def zrevrange(key, start, stop, options = {})
  node_for(key).zrevrange(key, start, stop, options)
end

#zrevrangebyscore(key, max, min, options = {}) ⇒ Object

Return a range of members in a sorted set, by score, with scores ordered from high to low.



456
457
458
 
# File 'lib/redis/distributed.rb', line 456

def zrevrangebyscore(key, max, min, options = {})
  node_for(key).zrevrangebyscore(key, max, min, options)
end

#zrevrank(key, member) ⇒ Object

Determine the index of a member in a sorted set, with scores ordered from high to low.



429
430
431
 
# File 'lib/redis/distributed.rb', line 429

def zrevrank(key, member)
  node_for(key).zrevrank(key, member)
end

#zscore(key, member) ⇒ Object

Get the score associated with the given member in a sorted set.



471
472
473
 
# File 'lib/redis/distributed.rb', line 471

def zscore(key, member)
  node_for(key).zscore(key, member)
end

#zunionstore(destination, keys, options = {}) ⇒ Object

Add multiple sorted sets and store the resulting sorted set in a new key.



484
485
486
487
488
 
# File 'lib/redis/distributed.rb', line 484

def zunionstore(destination, keys, options = {})
  ensure_same_node(:zunionstore, destination, *keys) do |node|
    node.zunionstore(destination, keys, options)
  end
end