Method: ZSpec::Queue#initialize

Defined in:
lib/zspec/queue.rb

#initialize(sink:, build_prefix:, retries:, timeout:) ⇒ Queue

Returns a new instance of Queue.



10
11
12
13
14
15
16
17
18
19
20
 
# File 'lib/zspec/queue.rb', line 10

def initialize(sink:, build_prefix:, retries:, timeout:)
  @sink                   = sink
  @retries                = retries.to_i
  @timeout                = timeout.to_i
  @counter_name           = build_prefix + ":count"
  @pending_queue_name     = build_prefix + ":pending"
  @processing_queue_name  = build_prefix + ":processing"
  @done_queue_name        = build_prefix + ":done"
  @metadata_hash_name     = build_prefix + ":metadata"
  @workers_ready_key_name = build_prefix + ":ready"
end