Class: Coordinator::Queue

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

Instance Method Summary collapse

Constructor Details

#initialize(skill, capacity = nil, &block) ⇒ Queue

Returns a new instance of Queue.



3
4
5
6
7
8
 
# File 'lib/coordinator/queue.rb', line 3

def initialize(skill, capacity=nil, &block)
  @skill = skill
  @store = Coordinator::RedisQueue.new(@skill)
  @store.capacity = capacity if capacity
  @custom_block = block if block_given?
end

Instance Method Details

#add_priority_task(task) ⇒ Object 



14
15
16
 
# File 'lib/coordinator/queue.rb', line 14

def add_priority_task(task)
  @store.left_push(task)
end

#add_task(task) ⇒ Object 



10
11
12
 
# File 'lib/coordinator/queue.rb', line 10

def add_task(task)
  @store.push(task)
end

#capacity ⇒ Object 



49
50
51
 
# File 'lib/coordinator/queue.rb', line 49

def capacity
  @store.capacity
end

#eligible?(task, skills) ⇒ Boolean

Returns:

  • (Boolean) 


29
30
31
32
33
34
35
 
# File 'lib/coordinator/queue.rb', line 29

def eligible?(task, skills)
  if @custom_block
    @custom_block.call(task, skills)
  else
    skills.include?(@skill)
  end
end

#items ⇒ Object 



45
46
47
 
# File 'lib/coordinator/queue.rb', line 45

def items
  @store.items
end

#length ⇒ Object 



53
54
55
 
# File 'lib/coordinator/queue.rb', line 53

def length
  @store.length
end

#name ⇒ Object 



41
42
43
 
# File 'lib/coordinator/queue.rb', line 41

def name
  @skill
end

#next_task(skills) ⇒ Object 



22
23
24
25
26
27
 
# File 'lib/coordinator/queue.rb', line 22

def next_task(skills)
  task = @store.peek
  return nil unless task && eligible?(task, skills)
  return task if @store.remove(task)
  next_task(skills)
end

#remove_task(task) ⇒ Object 



18
19
20
 
# File 'lib/coordinator/queue.rb', line 18

def remove_task(task)
  @store.remove(task)
end

#set_capacity(capacity) ⇒ Object 



37
38
39
 
# File 'lib/coordinator/queue.rb', line 37

def set_capacity(capacity)
  @store.capacity = capacity
end