Class: Coordinator::Base

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

Instance Method Summary collapse

Constructor Details

#initialize(queues) ⇒ Base

Returns a new instance of Base.



3
4
5
 
# File 'lib/coordinator/base.rb', line 3

def initialize(queues)
  @queues = queues
end

Instance Method Details

#add_priority_task(skill, task) ⇒ Object 



11
12
13
 
# File 'lib/coordinator/base.rb', line 11

def add_priority_task(skill, task)
  queue_for_skill(skill).add_priority_task(task)
end

#add_task(skill, task) ⇒ Object 



7
8
9
 
# File 'lib/coordinator/base.rb', line 7

def add_task(skill, task)
  queue_for_skill(skill).add_task(task)
end

#info(skill) ⇒ Object 



31
32
33
34
35
36
37
38
39
 
# File 'lib/coordinator/base.rb', line 31

def info(skill)
  queue = queue_for_skill(skill)
  {
    :skill => queue.skill,
    :capacity => queue.capacity,
    :count => queue.length,
    :items => queue.items
  }
end

#next_task(skills) ⇒ Object 



19
20
21
22
23
24
25
 
# File 'lib/coordinator/base.rb', line 19

def next_task(skills)
  @queues.each do |q|
    task = q.next_task(skills)
    return task if task
  end
  false
end

#remove_task(skill, task) ⇒ Object 



15
16
17
 
# File 'lib/coordinator/base.rb', line 15

def remove_task(skill, task)
  queue_for_skill(skill).remove_task(task)
end

#set_capacity(skill, capacity) ⇒ Object 



27
28
29
 
# File 'lib/coordinator/base.rb', line 27

def set_capacity(skill, capacity)
  queue_for_skill(skill).set_capacity(capacity)
end