class Qyu::Store::Base

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

Task

# 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

Job

# 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

Workflow

# 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