Module: Qs

Defined in:
lib/qs.rb,
lib/qs/cli.rb,
lib/qs/job.rb,
lib/qs/queue.rb,
lib/qs/route.rb,
lib/qs/client.rb,
lib/qs/daemon.rb,
lib/qs/logger.rb,
lib/qs/runner.rb,
lib/qs/io_pipe.rb,
lib/qs/process.rb,
lib/qs/version.rb,
lib/qs/pid_file.rb,
lib/qs/qs_runner.rb,
lib/qs/redis_item.rb,
lib/qs/config_file.rb,
lib/qs/daemon_data.rb,
lib/qs/job_handler.rb,
lib/qs/test_runner.rb,
lib/qs/test_helpers.rb,
lib/qs/error_handler.rb,
lib/qs/process_signal.rb,
lib/qs/payload_handler.rb

Defined Under Namespace

Modules: Client, Daemon, JobHandler, RedisUrl, TestHelpers Classes: CLI, CLIRB, Config, ConfigFile, DaemonData, ErrorContext, ErrorHandler, IOPipe, Job, Logger, NoHandlerClassError, NullLogger, PIDFile, PayloadHandler, Process, ProcessSignal, QsClient, QsRunner, Queue, RedisItem, RestartCmd, Route, Runner, TestClient, TestRunner

Constant Summary collapse

BadJobError = 
Class.new(ArgumentError)
VERSION = 
"0.3.0"
TimeoutError = 
Class.new(RuntimeError)
NotFoundError = 
Class.new(RuntimeError)
InvalidJobHandlerError = 
Class.new(StandardError)
ShutdownError = 
Class.new(DatWorkerPool::ShutdownError)

Class Method Summary collapse

Class Method Details

.client ⇒ Object 



54
55
56
 
# File 'lib/qs.rb', line 54

def self.client
  @client
end

.config ⇒ Object 



10
 
# File 'lib/qs.rb', line 10

def self.config; @config ||= Config.new; end

.configure(&block) ⇒ Object 



11
12
13
 
# File 'lib/qs.rb', line 11

def self.configure(&block)
  block.call(self.config)
end

.deserialize(serialized_payload) ⇒ Object 



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

def self.deserialize(serialized_payload)
  @deserializer.call(serialized_payload)
end

.enqueue(queue, job_name, params = nil) ⇒ Object 



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

def self.enqueue(queue, job_name, params = nil)
  @client.enqueue(queue, job_name, params)
end

.init ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/qs.rb', line 15

def self.init
  self.config.redis.url ||= RedisUrl.new(
    self.config.redis.ip,
    self.config.redis.port,
    self.config.redis.db
  )

  @serializer   ||= self.config.serializer
  @deserializer ||= self.config.deserializer
  @client       ||= Client.new(self.redis_config)
  @redis        ||= @client.redis
  true
end

.push(queue_name, payload) ⇒ Object 



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

def self.push(queue_name, payload)
  @client.push(queue_name, payload)
end

.redis ⇒ Object 



58
59
60
 
# File 'lib/qs.rb', line 58

def self.redis
  @redis
end

.redis_config ⇒ Object 



62
63
64
 
# File 'lib/qs.rb', line 62

def self.redis_config
  self.config.redis.to_hash
end

.reset! ⇒ Object 



29
30
31
32
33
34
35
36
 
# File 'lib/qs.rb', line 29

def self.reset!
  self.config.reset
  @serializer   = nil
  @deserializer = nil
  @client       = nil
  @redis        = nil
  true
end

.serialize(payload) ⇒ Object 



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

def self.serialize(payload)
  @serializer.call(payload)
end