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

#discard(job) ⇒ Object

Discards malformed job

Raises:

  • (NotImplementedError) 


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

def discard(job)
  raise NotImplementedError
end

#get_context(wfid) ⇒ Object

Raises:

  • (NotImplementedError) 


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

def get_context(wfid)
  raise NotImplementedError
end

#give_up(wfid, job, old_job) ⇒ Object

Gives up job after repeteadly failing to process it

Raises:

  • (NotImplementedError) 


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

def give_up(wfid, 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) 


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

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(wfid, jobs, jobmasks, context) ⇒ Object

Raises:

  • (NotImplementedError) 


37
38
39
 
# File 'lib/pallets/backends/base.rb', line 37

def run_workflow(wfid, jobs, jobmasks, context)
  raise NotImplementedError
end

#save(wfid, jid, 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(wfid, jid, job, context_buffer)
  raise NotImplementedError
end