Module cortex::dispatcher::server

Shared server utility functions between all dispatcher components

Functions

get_service	Getter for a Service stored inside an Arc<Mutex<HashMap>, with no DB access
get_sync_service	Memoized getter for a Service record from the backend
mark_done_arc	Persists a shared vector of reports to the Task store
pop_progress_task	Pops the next task from the progress queue
push_done_queue	Adds a task report to a shared report queue
push_progress_task	Pushes a new task on the progress queue
timeout_progress_tasks	Check for, remove and return any expired tasks from the progress queue