Class: Kaal::DelayedJob::Registry

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

Overview

Base abstraction for delayed-job persistence.

Instance Method Summary collapse

Instance Method Details

#all_jobsObject

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_strategyObject

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

#enqueueObject

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) ⇒ Object

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_dueObject

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