Class: Kaal::DelayedJob::Registry

Inherits:
Object
  • Object
show all
Defined in:
lib/kaal/delayed_job/registry.rb,
sig/kaal/delayed_job/registry.rbs

Overview

Base abstraction for delayed-job persistence.

Instance Method Summary collapse

Instance Method Details

#all_jobs ⇒ Kaal::rbs_any

Returns:

  • (Kaal::rbs_any)

Raises:

  • (NotImplementedError) 


26
27
28
 
# File 'lib/kaal/delayed_job/registry.rb', line 26

def all_jobs
  raise NotImplementedError, "#{self.class.name} must implement #all_jobs"
end

#claim_strategy ⇒ Kaal::rbs_any

Returns:

  • (Kaal::rbs_any)

Raises:

  • (NotImplementedError) 


30
31
32
 
# File 'lib/kaal/delayed_job/registry.rb', line 30

def claim_strategy
  raise NotImplementedError, "#{self.class.name} must implement #claim_strategy"
end

#enqueue ⇒ Kaal::rbs_any

Parameters:

  • (Kaal::rbs_any)

Returns:

  • (Kaal::rbs_any)

Raises:

  • (NotImplementedError) 


14
15
16
 
# File 'lib/kaal/delayed_job/registry.rb', line 14

def enqueue(**)
  raise NotImplementedError, "#{self.class.name} must implement #enqueue"
end

#find_job(_job_id) ⇒ Kaal::rbs_any

Parameters:

  • _job_id (Kaal::rbs_any)

Returns:

  • (Kaal::rbs_any)

Raises:

  • (NotImplementedError) 


22
23
24
 
# File 'lib/kaal/delayed_job/registry.rb', line 22

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

#pop_due ⇒ Kaal::rbs_any

Parameters:

  • (Kaal::rbs_any)

Returns:

  • (Kaal::rbs_any)

Raises:

  • (NotImplementedError) 


18
19
20
 
# File 'lib/kaal/delayed_job/registry.rb', line 18

def pop_due(**)
  raise NotImplementedError, "#{self.class.name} must implement #pop_due"
end

#requires_dispatch_lock? ⇒ Boolean

Returns:

  • (Boolean) 


34
35
36
 
# File 'lib/kaal/delayed_job/registry.rb', line 34

def requires_dispatch_lock?
  false
end