PACS System 0.1.0
PACS DICOM system library
Loading...
Searching...
No Matches
kcenon::pacs::workflow::task_scheduler Member List

This is the complete list of members for kcenon::pacs::workflow::task_scheduler, including all inherited members.

calculate_next_cron_run(const cron_schedule &cron, std::chrono::system_clock::time_point from) const -> std::optional< std::chrono::system_clock::time_point >kcenon::pacs::workflow::task_schedulerprivate
calculate_next_run(const kcenon::pacs::workflow::schedule &sched, std::chrono::system_clock::time_point from=std::chrono::system_clock::now()) const -> std::optional< std::chrono::system_clock::time_point >kcenon::pacs::workflow::task_schedulerprivate
cancel_task(const task_id &id) -> boolkcenon::pacs::workflow::task_scheduler
clear_history(const task_id &id, std::size_t keep_last=0)kcenon::pacs::workflow::task_scheduler
config_kcenon::pacs::workflow::task_schedulerprivate
create_archive_callback(const archive_config &config) -> task_callback_with_resultkcenon::pacs::workflow::task_schedulerprivate
create_cleanup_callback(const cleanup_config &config) -> task_callback_with_resultkcenon::pacs::workflow::task_schedulerprivate
create_verification_callback(const verification_config &config) -> task_callback_with_resultkcenon::pacs::workflow::task_schedulerprivate
cv_kcenon::pacs::workflow::task_schedulerprivate
database_kcenon::pacs::workflow::task_schedulerprivate
deserialize_tasks(const std::string &json) -> std::size_tkcenon::pacs::workflow::task_schedulerprivate
execute_cycle()kcenon::pacs::workflow::task_schedulerprivate
execute_task(scheduled_task &task) -> task_execution_recordkcenon::pacs::workflow::task_schedulerprivate
execution_history_kcenon::pacs::workflow::task_schedulerprivate
executor_kcenon::pacs::workflow::task_schedulerprivate
file_storage_kcenon::pacs::workflow::task_schedulerprivate
generate_execution_id() const -> std::stringkcenon::pacs::workflow::task_schedulerprivate
generate_task_id() const -> task_idkcenon::pacs::workflow::task_schedulerprivate
get_execution_history(const task_id &id, std::size_t limit=100) const -> std::vector< task_execution_record >kcenon::pacs::workflow::task_scheduler
get_recent_executions(std::size_t limit=100) const -> std::vector< task_execution_record >kcenon::pacs::workflow::task_scheduler
get_stats() const -> scheduler_statskcenon::pacs::workflow::task_scheduler
get_task(const task_id &id) const -> std::optional< scheduled_task >kcenon::pacs::workflow::task_scheduler
history_mutex_kcenon::pacs::workflow::task_schedulermutableprivate
is_running() const noexcept -> boolkcenon::pacs::workflow::task_scheduler
list_tasks() const -> std::vector< scheduled_task >kcenon::pacs::workflow::task_scheduler
list_tasks(task_type type) const -> std::vector< scheduled_task >kcenon::pacs::workflow::task_scheduler
list_tasks(task_state state) const -> std::vector< scheduled_task >kcenon::pacs::workflow::task_scheduler
load_tasks() -> std::size_tkcenon::pacs::workflow::task_scheduler
mutex_kcenon::pacs::workflow::task_schedulermutableprivate
next_execution_id_kcenon::pacs::workflow::task_schedulermutableprivate
next_task_id_kcenon::pacs::workflow::task_schedulermutableprivate
operator=(const task_scheduler &)=deletekcenon::pacs::workflow::task_scheduler
operator=(task_scheduler &&)=deletekcenon::pacs::workflow::task_scheduler
pause_task(const task_id &id) -> boolkcenon::pacs::workflow::task_scheduler
pending_count() const noexcept -> std::size_tkcenon::pacs::workflow::task_scheduler
record_execution(const task_id &task_id, const task_execution_record &record)kcenon::pacs::workflow::task_schedulerprivate
resume_task(const task_id &id) -> boolkcenon::pacs::workflow::task_scheduler
run_loop()kcenon::pacs::workflow::task_schedulerprivate
running_kcenon::pacs::workflow::task_schedulerprivate
running_count() const noexcept -> std::size_tkcenon::pacs::workflow::task_scheduler
running_count_kcenon::pacs::workflow::task_schedulerprivate
save_tasks() const -> boolkcenon::pacs::workflow::task_scheduler
schedule(const std::string &name, const std::string &description, std::chrono::seconds interval, task_callback_with_result callback) -> task_idkcenon::pacs::workflow::task_scheduler
schedule(const std::string &name, const std::string &description, const cron_schedule &cron_expr, task_callback_with_result callback) -> task_idkcenon::pacs::workflow::task_scheduler
schedule(scheduled_task task) -> task_idkcenon::pacs::workflow::task_scheduler
schedule_archive(const archive_config &config) -> task_idkcenon::pacs::workflow::task_scheduler
schedule_cleanup(const cleanup_config &config) -> task_idkcenon::pacs::workflow::task_scheduler
schedule_once(const std::string &name, const std::string &description, std::chrono::system_clock::time_point execute_at, task_callback_with_result callback) -> task_idkcenon::pacs::workflow::task_scheduler
schedule_verification(const verification_config &config) -> task_idkcenon::pacs::workflow::task_scheduler
scheduler_thread_kcenon::pacs::workflow::task_schedulerprivate
serialize_tasks() const -> std::stringkcenon::pacs::workflow::task_schedulerprivate
set_error_callback(task_scheduler_config::task_error_callback callback)kcenon::pacs::workflow::task_scheduler
set_task_complete_callback(task_scheduler_config::task_complete_callback callback)kcenon::pacs::workflow::task_scheduler
start()kcenon::pacs::workflow::task_scheduler
start_time_kcenon::pacs::workflow::task_schedulerprivate
stats_kcenon::pacs::workflow::task_schedulerprivate
stats_mutex_kcenon::pacs::workflow::task_schedulermutableprivate
stop(bool wait_for_completion=true)kcenon::pacs::workflow::task_scheduler
stop_requested_kcenon::pacs::workflow::task_schedulerprivate
task_scheduler(storage::index_database &database, const task_scheduler_config &config={})kcenon::pacs::workflow::task_schedulerexplicit
task_scheduler(storage::index_database &database, storage::file_storage &file_storage, std::shared_ptr< kcenon::thread::thread_pool > thread_pool, const task_scheduler_config &config={})kcenon::pacs::workflow::task_scheduler
task_scheduler(storage::index_database &database, storage::file_storage &file_storage, std::shared_ptr< kcenon::common::interfaces::IExecutor > executor, const task_scheduler_config &config={})kcenon::pacs::workflow::task_scheduler
task_scheduler(const task_scheduler &)=deletekcenon::pacs::workflow::task_scheduler
task_scheduler(task_scheduler &&)=deletekcenon::pacs::workflow::task_scheduler
tasks_kcenon::pacs::workflow::task_schedulerprivate
tasks_mutex_kcenon::pacs::workflow::task_schedulermutableprivate
thread_pool_kcenon::pacs::workflow::task_schedulerprivate
trigger_task(const task_id &id) -> boolkcenon::pacs::workflow::task_scheduler
update_schedule(const task_id &id, const kcenon::pacs::workflow::schedule &new_schedule) -> boolkcenon::pacs::workflow::task_scheduler
update_stats(const task_execution_record &record)kcenon::pacs::workflow::task_schedulerprivate
~task_scheduler()kcenon::pacs::workflow::task_scheduler