class Fluere::Worker::Base
Public Instance Methods
aws_flow_worker()
click to toggle source
# File lib/fluere/worker.rb, line 16 def aws_flow_worker @aws_flow_worker ||= worker_class.new( Fluere.swf.client, Fluere.domain, task_list, *task_implementations ) {{ logger: Fluere::Config.logger, use_forking: Fluere::Config.use_forking }} end
register()
click to toggle source
# File lib/fluere/worker.rb, line 36 def register aws_flow_worker.register end
run_once()
click to toggle source
# File lib/fluere/worker.rb, line 32 def run_once aws_flow_worker.run_once end
start()
click to toggle source
# File lib/fluere/worker.rb, line 28 def start aws_flow_worker.start end
task_implementations()
click to toggle source
# File lib/fluere/worker.rb, line 12 def task_implementations raise("abstract") end
task_list()
click to toggle source
# File lib/fluere/worker.rb, line 4 def task_list raise("abstract") end
worker_class()
click to toggle source
# File lib/fluere/worker.rb, line 8 def worker_class raise("abstract") end