Class: Pallets::Backends::Base

Inherits:
Object
  • Object
show all
Defined in:
lib/pallets/backends/base.rb

Direct Known Subclasses

Redis

Instance Method Summary collapse

Instance Method Details

#get_context(workflow_id) ⇒ Object

Raises:

  • (NotImplementedError) 


9
10
11
 
# File 'lib/pallets/backends/base.rb', line 9

def get_context(workflow_id)
  raise NotImplementedError
end

#give_up(job, old_job) ⇒ Object

Gives up job after repeteadly failing to process it

Raises:

  • (NotImplementedError) 


24
25
26
 
# File 'lib/pallets/backends/base.rb', line 24

def give_up(job, old_job)
  raise NotImplementedError
end

#pick ⇒ Object

Picks a job that is ready for processing

Raises:

  • (NotImplementedError) 


5
6
7
 
# File 'lib/pallets/backends/base.rb', line 5

def pick
  raise NotImplementedError
end

#reschedule_all(earlier_than) ⇒ Object

Raises:

  • (NotImplementedError) 


28
29
30
 
# File 'lib/pallets/backends/base.rb', line 28

def reschedule_all(earlier_than)
  raise NotImplementedError
end

#retry(job, old_job, at) ⇒ Object

Schedules a failed job for retry

Raises:

  • (NotImplementedError) 


19
20
21
 
# File 'lib/pallets/backends/base.rb', line 19

def retry(job, old_job, at)
  raise NotImplementedError
end

#run_workflow(workflow_id, jobs_with_dependencies, context) ⇒ Object

Raises:

  • (NotImplementedError) 


32
33
34
 
# File 'lib/pallets/backends/base.rb', line 32

def run_workflow(workflow_id, jobs_with_dependencies, context)
  raise NotImplementedError
end

#save(workflow_id, job, context_buffer) ⇒ Object

Saves a job after successfully processing it

Raises:

  • (NotImplementedError) 


14
15
16
 
# File 'lib/pallets/backends/base.rb', line 14

def save(workflow_id, job, context_buffer)
  raise NotImplementedError
end