class Blender::Task::SerfAsync
Attributes
check_query[R]
reap_query[R]
start_query[R]
Public Class Methods
new(name, options = {})
click to toggle source
Calls superclass method
# File lib/blender/tasks/serf_async.rb, line 24 def initialize(name, options = {}) super @start_query = Blender::Task::Serf.new(name) @start_query.payload(metadata[:start]) @start_query.timeout(metadata[:timeout]) @start_query.no_ack(metadata[:no_ack]) @start_query.process(&metadata[:process]) @reap_query = Blender::Task::Serf.new(name) @reap_query.payload(metadata[:reap]) @reap_query.timeout(metadata[:timeout]) @reap_query.no_ack(metadata[:no_ack]) @reap_query.process(&metadata[:process]) @check_query = Blender::Task::Serf.new(name) @check_query.payload(metadata[:check]) @check_query.timeout(metadata[:timeout]) @check_query.no_ack(metadata[:no_ack]) @check_query.process(&metadata[:process]) end
Public Instance Methods
check(&block)
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 59 def check(&block) @check_query.instance_eval(&block) end
command()
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 66 def command end
default_metadata()
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 73 def default_metadata { ignore_failure: false, start: 'start', reap: 'reap', check: 'check', timeout: 5, no_ack: false, process: nil, retry_options: { intervals: Array.new(5, 30) } } end
execute()
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 63 def execute end
query(event)
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 45 def query(event) @start_query.query(event) @reap_query.query(event) @check_query.query(event) end
reap(&block)
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 55 def reap(&block) @reap_query.instance_eval(&block) end
retry_options(options = {})
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 69 def retry_options(options = {}) @metadata[:retry_options] = options end
start(&block)
click to toggle source
# File lib/blender/tasks/serf_async.rb, line 51 def start(&block) @start_query.instance_eval(&block) end