Class: RSpec::Sidekiq::NamedQueues::JobStore

Inherits:
Object
  • Object
show all
Defined in:
lib/rspec/sidekiq/named_queues/job_store.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ JobStore

Returns a new instance of JobStore.



11
12
13
14
15
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 11

def initialize
  @scheduled = []
  @retry_set = []
  @dead = []
end

Instance Attribute Details

#dead ⇒ Object (readonly)

Returns the value of attribute dead.



9
10
11
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 9

def dead
  @dead
end

#retry_set ⇒ Object (readonly)

Returns the value of attribute retry_set.



9
10
11
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 9

def retry_set
  @retry_set
end

#scheduled ⇒ Object (readonly)

Returns the value of attribute scheduled.



9
10
11
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 9

def scheduled
  @scheduled
end

Instance Method Details

#add_dead(item) ⇒ Object 



33
34
35
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 33

def add_dead(item)
  @dead << normalize_item(item)
end

#add_retry(item) ⇒ Object 



29
30
31
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 29

def add_retry(item)
  @retry_set << normalize_item(item)
end

#clear! ⇒ Object 



37
38
39
40
41
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 37

def clear!
  @scheduled.clear
  @retry_set.clear
  @dead.clear
end

#push(item) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/rspec/sidekiq/named_queues/job_store.rb', line 17

def push(item)
  jid = extract_or_assign_jid(item)
  payload = normalize_item(item)
  payload["jid"] ||= jid

  if payload.key?("at")
    @scheduled << payload
  end

  payload
end