Module: Subservient

Defined in:
lib/subservient/job.rb,
lib/subservient/task.rb,
lib/subservient/config.rb,
lib/subservient/errors.rb,
lib/subservient/worker.rb,
lib/subservient/version.rb

Defined Under Namespace

Classes: AlreadyRunningError, BuryJob, Job, JobError, MalformedJobError, MissingTaskError, RetryJob, SubservientError, Task, TaskError, Worker, WorkerError

Constant Summary collapse

VERSION = 
'0.0.1'
@@tasks = 
[]
@@namespace = 
'subservient'
@@pool_urls = 
['localhost:11300']

Class Method Summary collapse

Class Method Details

.namespace ⇒ Object 



3
4
5
 
# File 'lib/subservient/config.rb', line 3

def self.namespace
  @@namespace
end

.namespace=(value) ⇒ Object 



6
7
8
 
# File 'lib/subservient/config.rb', line 6

def self.namespace= value
  @@namespace = value
end

.pool ⇒ Object 



12
13
14
 
# File 'lib/subservient/config.rb', line 12

def self.pool
  @@pool_urls
end

.pool=(value) ⇒ Object 



15
16
17
 
# File 'lib/subservient/config.rb', line 15

def self.pool= value
  @@pool_urls = value
end

.tasks ⇒ Object 



40
41
42
43
44
45
46
47
48
 
# File 'lib/subservient/task.rb', line 40

def self.tasks
  if @@tasks.empty?
    ObjectSpace.each_object(Module) do |m|
      @@tasks << m if m.ancestors.include? Subservient::Task
    end
    @@tasks -= [Subservient::Task]
  end
  return @@tasks
end