rumtk_web/utils/
jobs.rs

1/*
2 * rumtk attempts to implement HL7 and medical protocols for interoperability in medicine.
3 * This toolkit aims to be reliable, simple, performant, and standards compliant.
4 * Copyright (C) 2025  Luis M. Santos, M.D.
5 * Copyright (C) 2025  Nick Stephenson
6 * Copyright (C) 2025  Ethan Dixon
7 * Copyright (C) 2025  MedicalMasses L.L.C.
8 *
9 * This library is free software; you can redistribute it and/or
10 * modify it under the terms of the GNU Lesser General Public
11 * License as published by the Free Software Foundation; either
12 * version 2.1 of the License, or (at your option) any later version.
13 *
14 * This library is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
17 * Lesser General Public License for more details.
18 *
19 * You should have received a copy of the GNU Lesser General Public
20 * License along with this library; if not, write to the Free Software
21 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
22 */
23use rumtk_core::core::RUMResult;
24use rumtk_core::id::id_to_uuid;
25use rumtk_core::strings::RUMString;
26use rumtk_core::threading::threading_manager::{Task, TaskID, TaskManager};
27use rumtk_core::types::RUMBuffer;
28
29pub type JobID = TaskID;
30pub type JobBuffer = RUMBuffer;
31
32#[derive(Default, Debug, Clone)]
33pub enum JobResultType<T = RUMString> {
34    File(JobBuffer),
35    JSON(RUMString),
36    TEXT(RUMString),
37    RustType(T),
38    #[default]
39    NONE,
40}
41
42pub type JobResult = RUMResult<JobResultType>;
43pub type Job = Task<JobResult>;
44type JobManager = TaskManager<JobResult>;
45
46static mut TASK_MANAGER: Option<JobManager> = None;
47
48pub fn job_str_id_to_id(id: &str) -> JobID {
49    id_to_uuid(id)
50}
51
52pub fn init_job_manager(workers: &usize) -> RUMResult<()> {
53    let manager = TaskManager::<JobResult>::new(workers)?;
54    unsafe {
55        TASK_MANAGER = Some(manager);
56    }
57    Ok(())
58}
59
60pub fn get_manager() -> &'static mut JobManager {
61    let mut manager = unsafe { TASK_MANAGER.as_mut().unwrap() };
62    manager
63}
64
65#[macro_export]
66macro_rules! rumtk_web_init_job_manager {
67    ( $workers:expr ) => {{
68        use $crate::jobs::init_job_manager;
69        init_job_manager($workers)
70    }};
71}
72
73#[macro_export]
74macro_rules! rumtk_web_get_job_manager {
75    (  ) => {{
76        use $crate::jobs::get_manager;
77        get_manager()
78    }};
79}
80
81#[macro_export]
82macro_rules! rumtk_web_generate_job_id {
83    ( $id:expr ) => {{
84        use $crate::jobs::job_str_id_to_id;
85        job_str_id_to_id($id)
86    }};
87}
rumtk_web/utils/jobs.rs

rumtk_web/utils/
jobs.rs
