Module: CI::Queue::Redis

Defined in:
lib/ci/queue/redis.rb,
lib/ci/queue/redis/base.rb,
lib/ci/queue/redis/grind.rb,
lib/ci/queue/redis/retry.rb,
lib/ci/queue/redis/worker.rb,
lib/ci/queue/redis/monitor.rb,
lib/ci/queue/redis/supervisor.rb,
lib/ci/queue/redis/build_record.rb,
lib/ci/queue/redis/grind_record.rb,
lib/ci/queue/redis/grind_supervisor.rb,
lib/ci/queue/redis/test_time_record.rb

Defined Under Namespace

Classes: Base, BuildRecord, Grind, GrindRecord, GrindSupervisor, Monitor, Retry, Supervisor, TestTimeRecord, 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.



11
12
13
 
# File 'lib/ci/queue/redis/worker.rb', line 11

def requeue_offset
  @requeue_offset
end

Class Method Details

.from_uri(uri, config) ⇒ Object 



26
27
28
 
# File 'lib/ci/queue/redis.rb', line 26

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

.new(*args) ⇒ Object 



22
23
24
 
# File 'lib/ci/queue/redis.rb', line 22

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