Class: Redis::Unique::Queue

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

Defined Under Namespace

Classes: InvalidNameException, InvalidRedisConfigException

Constant Summary collapse

VERSION = 
"1.0.2"

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name, redis_or_options = {}) ⇒ Queue

Returns a new instance of Queue.

Raises:



13
14
15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/redis/unique/queue.rb', line 13

def initialize(name, redis_or_options = {})
  name = name.to_s if name.kind_of? Symbol
  
  raise InvalidNameException.new unless name.kind_of?(String) && name.size > 0
  @name  = name
  @redis = if redis_or_options.kind_of? Redis
             redis_or_options
           elsif redis_or_options.kind_of? Hash
             Redis.new redis_or_options
           else
            raise InvalidRedisConfigException.new
           end
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



6
7
8
 
# File 'lib/redis/unique/queue.rb', line 6

def name
  @name
end

Instance Method Details

#all ⇒ Object 



78
79
80
 
# File 'lib/redis/unique/queue.rb', line 78

def all
  peek 0, size
end

#back ⇒ Object 



62
63
64
 
# File 'lib/redis/unique/queue.rb', line 62

def back
  @redis.zrevrange(name, 0, 0).first
end

#clear ⇒ Object 



90
91
92
93
 
# File 'lib/redis/unique/queue.rb', line 90

def clear
  @redis.del name
  []
end

#expire(seconds) ⇒ Object 



95
96
97
 
# File 'lib/redis/unique/queue.rb', line 95

def expire seconds
  @redis.expire name, seconds
end

#front ⇒ Object 



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

def front
  @redis.zrange(name, 0, 0).first
end

#include?(data) ⇒ Boolean

Returns:

  • (Boolean) 


86
87
88
 
# File 'lib/redis/unique/queue.rb', line 86

def include? data
  !@redis.zscore(name, data).nil?
end

#peek(index, amount = 1) ⇒ Object 



82
83
84
 
# File 'lib/redis/unique/queue.rb', line 82

def peek index, amount=1
  @redis.zrange name, index, index + amount - 1
end

#pop ⇒ Object 



46
47
48
 
# File 'lib/redis/unique/queue.rb', line 46

def pop
  block_on_atomic_attempt{ attempt_atomic_pop }
end

#pop_all ⇒ Object 



50
51
52
 
# File 'lib/redis/unique/queue.rb', line 50

def pop_all
  block_on_atomic_attempt{ attempt_atomic_pop_all }
end

#pop_multi(amount) ⇒ Object 



54
55
56
 
# File 'lib/redis/unique/queue.rb', line 54

def pop_multi amount
  block_on_atomic_attempt{ attempt_atomic_pop_multi amount }
end

#push(data) ⇒ Object 



27
28
29
30
 
# File 'lib/redis/unique/queue.rb', line 27

def push data
  score = Time.now.to_f
  @redis.zadd(name, score, data)
end

#push_multi(*values) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/redis/unique/queue.rb', line 32

def push_multi *values
  if values.size > 0
    score = Time.now.to_f

    values = values.first if 1 == values.size && values.first.kind_of?(Array)
    scored_values = []
    values.each_with_index do |value, i|
      scored_values << [score + i, value]
    end

    @redis.zadd name, scored_values
  end
end

#remove(data) ⇒ Object 



66
67
68
 
# File 'lib/redis/unique/queue.rb', line 66

def remove data
  @redis.zrem name, data
end

#remove_item_by_index(index) ⇒ Object 



70
71
72
 
# File 'lib/redis/unique/queue.rb', line 70

def remove_item_by_index index
  @redis.zremrangebyrank name, index, index
end

#size ⇒ Object 



74
75
76
 
# File 'lib/redis/unique/queue.rb', line 74

def size
  @redis.zcard name
end