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