Class: Disc

Inherits:
Object
  • Object
show all
Defined in:
lib/disc.rb,
lib/disc/version.rb

Defined Under Namespace

Modules: Job Classes: Worker

Constant Summary collapse

VERSION = 
"0.0.15"

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Attribute Details

#disque ⇒ Object (readonly)

Returns the value of attribute disque.



8
9
10
 
# File 'lib/disc.rb', line 8

def disque
  @disque
end

#disque_timeout ⇒ Object (readonly)

Returns the value of attribute disque_timeout.



8
9
10
 
# File 'lib/disc.rb', line 8

def disque_timeout
  @disque_timeout
end

Class Method Details

.disque ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/disc.rb', line 11

def self.disque
  @disque ||= Disque.new(
    ENV.fetch('DISQUE_NODES', 'localhost:7711'),
    auth: ENV.fetch('DISQUE_AUTH', nil),
    cycle: Integer(ENV.fetch('DISQUE_CYCLE', '1000'))
  )
end

.disque=(disque) ⇒ Object 



19
20
21
 
# File 'lib/disc.rb', line 19

def self.disque=(disque)
  @disque = disque
end

.disque_timeout ⇒ Object 



23
24
25
 
# File 'lib/disc.rb', line 23

def self.disque_timeout
  @disque_timeout ||= 100
end

.disque_timeout=(timeout) ⇒ Object 



27
28
29
 
# File 'lib/disc.rb', line 27

def self.disque_timeout=(timeout)
  @disque_timeout = timeout
end

.on_error(exception, job) ⇒ Object 



31
32
33
 
# File 'lib/disc.rb', line 31

def self.on_error(exception, job)
  $stderr.puts exception
end