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