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/key_shortener.rb,
lib/ci/queue/redis/grind_supervisor.rb,
lib/ci/queue/redis/test_time_record.rb

Defined Under Namespace

Modules: KeyShortener Classes: Base, BuildRecord, Grind, GrindRecord, GrindSupervisor, Monitor, Retry, Supervisor, TestTimeRecord, Worker

Constant Summary collapse

LostMaster = 
Class.new(CI::Queue::Error)
ReservationError = 
Class.new(CI::Queue::Error)

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.max_sleep_time ⇒ Object

Returns the value of attribute max_sleep_time.



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

def max_sleep_time
  @max_sleep_time
end

.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 



28
29
30
 
# File 'lib/ci/queue/redis.rb', line 28

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

.new(*args) ⇒ Object 



24
25
26
 
# File 'lib/ci/queue/redis.rb', line 24

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