Source: factory.core/ObjSupervisor.py
Summary of what the class does.
The Supervisor class is responsible for managing and monitoring various system
processes and services within a distributed environment. This includes handling
database reconnections, tracking system load, managing service statuses,
...
| Method | Signature | Description |
|---|---|---|
| acquire_lock | acquire_lock(context: str = '', iteration = 1) |
|
| release_lock | release_lock(locked_file_descriptor) |
release exclusive lock file access |
| reconnect_check | reconnect_check() |
|
| get_system_load | get_system_load() |
|
| Status | Status() |
|
| action_service | action_service(Service, Thread) |
|
| special_purpose_process | special_purpose_process() -> None |
Deal with messages that are not initiated by the system; eg. a file on a filesystem |
| dispatcher_direct | dispatcher_direct(context: str, queue: str, payload: dict) |
|
| dispatcher_process | dispatcher_process(sleep_time = 1) |
|
| worker_process | worker_process(name: str, sleep_time = 1) |
|
| move_to_history | move_to_history(StageGuid, ReadStatus = True) |
|
| reset_stage | reset_stage() |
|
| ClearOutToHistory | ClearOutToHistory() |
|
| run_service | run_service(service: str, role = '', guid = '') |
|
| base_service | base_service(role = 'dispatcher', name = '') |
|
| factory_list | factory_list(base_dir) |
|
| build_mermaid | build_mermaid(list_items: list, parent) |
|
| scan_factory | scan_factory(service: str, factory: str = '') |
Run preflight checks.
Scan a factory module for class diagrams.