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.27"

Class Method Summary collapse

Class Method Details

.default_queue ⇒ Object 



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

def self.default_queue
  @default_queue ||= 'default'
end

.default_queue=(queue) ⇒ Object 



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

def self.default_queue=(queue)
  @default_queue = queue
end

.deserialize(data) ⇒ Object 



50
51
52
 
# File 'lib/disc.rb', line 50

def self.deserialize(data)
  JSON.parse(data)
end

.disque ⇒ Object 



6
7
8
9
10
11
12
 
# File 'lib/disc.rb', line 6

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 



14
15
16
 
# File 'lib/disc.rb', line 14

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

.disque_timeout ⇒ Object 



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

def self.disque_timeout
  @disque_timeout ||= ENV.fetch('DISQUE_TIMEOUT', 100)
end

.disque_timeout=(timeout) ⇒ Object 



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

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

.flush ⇒ Object 



38
39
40
 
# File 'lib/disc.rb', line 38

def self.flush
  Disc.disque.call('DEBUG', 'FLUSHALL')
end

.on_error(exception, job) ⇒ Object 



42
43
44
 
# File 'lib/disc.rb', line 42

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

.qlen(queue) ⇒ Object 



34
35
36
 
# File 'lib/disc.rb', line 34

def self.qlen(queue)
  disque.call('QLEN', queue)
end

.serialize(args) ⇒ Object 



46
47
48
 
# File 'lib/disc.rb', line 46

def self.serialize(args)
  JSON.dump(args)
end