| Commit message (Collapse) | Author | Age | Files | Lines |
| | |
|
| | |
|
| |
|
|
| |
- starts emq-cli and implements status for the router
|
| | |
|
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
- Rename `WORKERS` setting to `CONCURRENT_JOBS` for more clarity. Added this
setting to the command line options, the ini .conf & default settings conf.py
files.
- Added support for JSON style arrays in INI config.
- Added support for weighted named queues. The style for the setting is
[[weight, "name"], [weight, "name"]]. Configured in both the INI and command
line for job manager. Added documentation.
- Updated the spec for the INFORM message. Weights are sent with the queue
names. If there are no weights specified they will be given the default value
of 0.
- updated Router.queues to a list from a deque so that it can be sorted
by priority more easily.
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| | |
|
| |
|
|
|
|
| |
- JobManager now replies with READY when it's 'finished' with the job to
requeue the worker in the broker.
- some improvements to logging that prevents duplicate messages
|
| |
|
|
|
|
| |
Router joins the love
HeartbeatMixin refactored
Added forgotten timeutils
|
| |
|
|
| |
Added a monotonic to JobWorker to schedule heartbeast
|
| |
|
|
|
| |
- organizes some code
- Router sends acknowledgement after jobmanager INFORMs
|
| | |
|
| | |
|
| |
|