class Swarm::Engine::Queue

Attributes

name[R]

Public Class Methods

new(name:) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 11
def initialize(name:)
  @name = name
end

Public Instance Methods

add_job(data) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 19
def add_job(data)
  raise "Not implemented yet!"
end
bury_job(job) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 31
def bury_job(job)
  job.bury if job.exists?
end
clean_up_job(job) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 35
def clean_up_job(job)
  job.bury if job.exists? && job.reserved?
end
clear() click to toggle source
# File lib/swarm/engine/base/queue.rb, line 47
def clear
  raise "Not implemented yet!"
end
delete_job(job) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 27
def delete_job(job)
  job.delete
end
idle?() click to toggle source
# File lib/swarm/engine/base/queue.rb, line 51
def idle?
  raise "Not implemented yet!"
end
prepare_for_work(worker) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 15
def prepare_for_work(worker)
  raise "Not implemented yet!"
end
remove_worker(worker, stop_job:) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 39
def remove_worker(worker, stop_job:)
  if worker_count <= 1
    stop_job.delete
  else
    stop_job.release
  end
end
reserve_job(worker) click to toggle source
# File lib/swarm/engine/base/queue.rb, line 23
def reserve_job(worker)
  raise "Not implemented yet!"
end
worker_count() click to toggle source
# File lib/swarm/engine/base/queue.rb, line 55
def worker_count
  raise "Not implemented yet!"
end