Module: CI::Queue::Redis

Defined in:
lib/ci/queue/redis.rb,
lib/ci/queue/redis/base.rb,
lib/ci/queue/redis/retry.rb,
lib/ci/queue/redis/worker.rb,
lib/ci/queue/redis/supervisor.rb

Defined Under Namespace

Classes: Base, Retry, Supervisor, Worker

Constant Summary collapse

Error = 
Class.new(StandardError)
LostMaster = 
Class.new(Error)
ReservationError = 
Class.new(StandardError)

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.requeue_offset ⇒ Object

Returns the value of attribute requeue_offset.



9
10
11
 
# File 'lib/ci/queue/redis/worker.rb', line 9

def requeue_offset
  @requeue_offset
end

Class Method Details

.from_uri(uri, config) ⇒ Object 



19
20
21
 
# File 'lib/ci/queue/redis.rb', line 19

def from_uri(uri, config)
  new(uri.to_s, config)
end

.new(*args) ⇒ Object 



15
16
17
 
# File 'lib/ci/queue/redis.rb', line 15

def new(*args)
  Worker.new(*args)
end