Class: Delayed::Master::Worker

Inherits:
Object
  • Object
show all
Defined in:
lib/delayed/master/worker.rb,
lib/delayed/master/worker/thread_pool.rb,
lib/delayed/master/worker/thread_worker.rb,
lib/delayed/master/worker/plugins/memory_checker.rb,
lib/delayed/master/worker/plugins/signal_handler.rb,
lib/delayed/master/worker/plugins/status_notifier.rb,
lib/delayed/master/worker/plugins/executor_wrapper.rb

Defined Under Namespace

Modules: Plugins, ThreadWorker Classes: ThreadPool

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(attrs = {}) ⇒ Worker

Returns a new instance of Worker.



9
10
11
12
13
 
# File 'lib/delayed/master/worker.rb', line 9

def initialize(attrs = {})
  attrs.each do |k, v|
    send("#{k}=", v)
  end
end

Instance Attribute Details

#database ⇒ Object

Returns the value of attribute database.



6
7
8
 
# File 'lib/delayed/master/worker.rb', line 6

def database
  @database
end

#instance ⇒ Object

Returns the value of attribute instance.



7
8
9
 
# File 'lib/delayed/master/worker.rb', line 7

def instance
  @instance
end

#pid ⇒ Object

Returns the value of attribute pid.



7
8
9
 
# File 'lib/delayed/master/worker.rb', line 7

def pid
  @pid
end

#setting ⇒ Object

Returns the value of attribute setting.



6
7
8
 
# File 'lib/delayed/master/worker.rb', line 6

def setting
  @setting
end

Instance Method Details

#info ⇒ Object 



19
20
21
22
23
 
# File 'lib/delayed/master/worker.rb', line 19

def info
  strs = [@setting.worker_info]
  strs << "@#{@database.spec_name}" if @database
  strs.join(' ')
end

#name ⇒ Object 



15
16
17
 
# File 'lib/delayed/master/worker.rb', line 15

def name
  "worker[#{@setting.id}]"
end

#process_title ⇒ Object 



25
26
27
 
# File 'lib/delayed/master/worker.rb', line 25

def process_title
  "delayed_job: #{info}"
end