Class: JobWorkflow::QueueAdapters::Abstract

Inherits:
Object
  • Object
show all
Defined in:
lib/job_workflow/queue_adapters/abstract.rb

Overview

rubocop:disable Naming/PredicateMethod

Direct Known Subclasses

NullAdapter, SolidQueueAdapter

Instance Method Summary collapse

Instance Method Details

#clear_queue(_queue_name) ⇒ Object

: (String) -> bool

Raises:

  • (NotImplementedError) 


71
72
73
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 71

def clear_queue(_queue_name)
  raise NotImplementedError, "#{self.class}#clear_queue must be implemented"
end

#fetch_job_contexts(_job_ids) ⇒ Object

: (Array) -> Array[Hash[String, untyped]]

Raises:

  • (NotImplementedError) 


81
82
83
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 81

def fetch_job_contexts(_job_ids)
  raise NotImplementedError, "#{self.class}#fetch_job_contexts must be implemented"
end

#fetch_job_statuses(job_ids) ⇒ Object

: (Array) -> Hash[String, untyped]

Raises:

  • (NotImplementedError) 


26
27
28
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 26

def fetch_job_statuses(job_ids)
  raise NotImplementedError, "#{self.class}#fetch_job_statuses must be implemented"
end

#find_job(_job_id) ⇒ Object

: (String) -> Hash[String, untyped]?

Raises:

  • (NotImplementedError) 


76
77
78
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 76

def find_job(_job_id)
  raise NotImplementedError, "#{self.class}#find_job must be implemented"
end

#initialize_adapter! ⇒ Object

: () -> void



8
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 8

def initialize_adapter!; end

#job_status(job) ⇒ Object

: (untyped) -> Symbol

Raises:

  • (NotImplementedError) 


31
32
33
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 31

def job_status(job)
  raise NotImplementedError, "#{self.class}#job_status must be implemented"
end

#pause_queue(_queue_name) ⇒ Object

: (String) -> bool

Raises:

  • (NotImplementedError) 


41
42
43
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 41

def pause_queue(_queue_name)
  raise NotImplementedError, "#{self.class}#pause_queue must be implemented"
end

#paused_queues ⇒ Object

: () -> Array

Raises:

  • (NotImplementedError) 


56
57
58
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 56

def paused_queues
  raise NotImplementedError, "#{self.class}#paused_queues must be implemented"
end

#persist_job_context(_job) ⇒ Object

: (DSL) -> void



91
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 91

def persist_job_context(_job); end

#queue_latency(_queue_name) ⇒ Object

: (String) -> Integer?

Raises:

  • (NotImplementedError) 


61
62
63
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 61

def queue_latency(_queue_name)
  raise NotImplementedError, "#{self.class}#queue_latency must be implemented"
end

#queue_paused?(_queue_name) ⇒ Boolean

: (String) -> bool

Returns:

  • (Boolean)

Raises:

  • (NotImplementedError) 


51
52
53
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 51

def queue_paused?(_queue_name)
  raise NotImplementedError, "#{self.class}#queue_paused? must be implemented"
end

#queue_size(_queue_name) ⇒ Object

: (String) -> Integer

Raises:

  • (NotImplementedError) 


66
67
68
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 66

def queue_size(_queue_name)
  raise NotImplementedError, "#{self.class}#queue_size must be implemented"
end

#reschedule_job(_job, _wait) ⇒ Object

: (DSL, Numeric) -> bool



86
87
88
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 86

def reschedule_job(_job, _wait)
  false
end

#resume_queue(_queue_name) ⇒ Object

: (String) -> bool

Raises:

  • (NotImplementedError) 


46
47
48
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 46

def resume_queue(_queue_name)
  raise NotImplementedError, "#{self.class}#resume_queue must be implemented"
end

#semaphore_available? ⇒ Boolean

: () -> bool

Returns:

  • (Boolean)

Raises:

  • (NotImplementedError) 


11
12
13
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 11

def semaphore_available?
  raise NotImplementedError, "#{self.class}#semaphore_available? must be implemented"
end

#semaphore_signal(semaphore) ⇒ Object

: (Semaphore) -> bool

Raises:

  • (NotImplementedError) 


21
22
23
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 21

def semaphore_signal(semaphore)
  raise NotImplementedError, "#{self.class}#semaphore_signal must be implemented"
end

#semaphore_wait(semaphore) ⇒ Object

: (Semaphore) -> bool

Raises:

  • (NotImplementedError) 


16
17
18
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 16

def semaphore_wait(semaphore)
  raise NotImplementedError, "#{self.class}#semaphore_wait must be implemented"
end

#supports_concurrency_limits? ⇒ Boolean

: () -> bool

Returns:

  • (Boolean)

Raises:

  • (NotImplementedError) 


36
37
38
 
# File 'lib/job_workflow/queue_adapters/abstract.rb', line 36

def supports_concurrency_limits?
  raise NotImplementedError, "#{self.class}#supports_concurrency_limits? must be implemented"
end