class Qyu::Store::Base
Public Class Methods
valid_config?(_config)
click to toggle source
This class acts as an interface for any store implemented for Qyu
Implement the following methods in any store and it should work seemlessly
# File lib/qyu/store/base.rb, line 9 def self.valid_config?(_config) fail Qyu::Errors::NotImplementedError end
Public Instance Methods
clear_completed_jobs()
click to toggle source
# File lib/qyu/store/base.rb, line 59 def clear_completed_jobs fail Qyu::Errors::NotImplementedError end
count_jobs()
click to toggle source
# File lib/qyu/store/base.rb, line 51 def count_jobs fail Qyu::Errors::NotImplementedError end
delete_job(_id)
click to toggle source
# File lib/qyu/store/base.rb, line 55 def delete_job(_id) fail Qyu::Errors::NotImplementedError end
delete_workflow(_id)
click to toggle source
# File lib/qyu/store/base.rb, line 30 def delete_workflow(_id) fail Qyu::Errors::NotImplementedError end
delete_workflow_by_name(name)
click to toggle source
# File lib/qyu/store/base.rb, line 34 def delete_workflow_by_name(name) fail Qyu::Errors::NotImplementedError end
find_job(_id)
click to toggle source
# File lib/qyu/store/base.rb, line 43 def find_job(_id) fail Qyu::Errors::NotImplementedError end
find_or_persist_task(_name, _payload, _job_id, _parent_task_id)
click to toggle source
# File lib/qyu/store/base.rb, line 65 def find_or_persist_task(_name, _payload, _job_id, _parent_task_id) fail Qyu::Errors::NotImplementedError end
find_task(_id)
click to toggle source
# File lib/qyu/store/base.rb, line 69 def find_task(_id) fail Qyu::Errors::NotImplementedError end
find_task_ids_by_job_id_and_name(_job_id, _name)
click to toggle source
# File lib/qyu/store/base.rb, line 73 def find_task_ids_by_job_id_and_name(_job_id, _name) fail Qyu::Errors::NotImplementedError end
find_task_ids_by_job_id_name_and_parent_task_ids(_job_id, _name, _parent_task_ids)
click to toggle source
# File lib/qyu/store/base.rb, line 77 def find_task_ids_by_job_id_name_and_parent_task_ids(_job_id, _name, _parent_task_ids) fail Qyu::Errors::NotImplementedError end
find_workflow(_id)
click to toggle source
# File lib/qyu/store/base.rb, line 22 def find_workflow(_id) fail Qyu::Errors::NotImplementedError end
find_workflow_by_name(_name)
click to toggle source
# File lib/qyu/store/base.rb, line 26 def find_workflow_by_name(_name) fail Qyu::Errors::NotImplementedError end
lock_task!(_id, _lease_time)
click to toggle source
# File lib/qyu/store/base.rb, line 81 def lock_task!(_id, _lease_time) fail Qyu::Errors::NotImplementedError end
persist_job(_workflow, _payload)
click to toggle source
# File lib/qyu/store/base.rb, line 39 def persist_job(_workflow, _payload) fail Qyu::Errors::NotImplementedError end
persist_workflow(name, descriptor)
click to toggle source
# File lib/qyu/store/base.rb, line 18 def persist_workflow(name, descriptor) fail Qyu::Errors::NotImplementedError end
renew_lock_lease(_id, _lease_time, _lease_token)
click to toggle source
# File lib/qyu/store/base.rb, line 89 def renew_lock_lease(_id, _lease_time, _lease_token) fail Qyu::Errors::NotImplementedError end
select_jobs(_limit, _offset, _order = :asc)
click to toggle source
# File lib/qyu/store/base.rb, line 47 def select_jobs(_limit, _offset, _order = :asc) fail Qyu::Errors::NotImplementedError end
select_tasks_by_job_id()
click to toggle source
# File lib/qyu/store/base.rb, line 101 def select_tasks_by_job_id fail Qyu::Errors::NotImplementedError end
task_status_counts(_job_id)
click to toggle source
# File lib/qyu/store/base.rb, line 97 def task_status_counts(_job_id) fail Qyu::Errors::NotImplementedError end
transaction()
click to toggle source
# File lib/qyu/store/base.rb, line 13 def transaction fail Qyu::Errors::NotImplementedError end
unlock_task!(_id, _lease_token)
click to toggle source
# File lib/qyu/store/base.rb, line 85 def unlock_task!(_id, _lease_token) fail Qyu::Errors::NotImplementedError end
update_status(_id, _status)
click to toggle source
# File lib/qyu/store/base.rb, line 93 def update_status(_id, _status) fail Qyu::Errors::NotImplementedError end