aboutsummaryrefslogtreecommitdiffstats
path: root/bin (follow)
Commit message (Collapse)AuthorAgeFilesLines
* Fix Python 2/3 compatibility issuestpavelchak2020-02-071-1/+3
| | | | | | | | | | | | | | - version bump 0.3.12 - upgrade `six, flake8` libs - fix `flake8` check issues - add import of `from __future__ import print_function` - fix params for `zsocket.setsockopt()` and `hashlib.sha1()` methods - use `range, map` functions from `six` - wrap result of `map, dict.keys(), dict.values()` functions in a list - fix `EMQdeque.__unicode__()` method for py2 support - fix using of exception messages - update integer division for support the same behavior in py3 as is in py2 - refactor using of `filter` function
* Update print, xrange and unicode functions for python 2/3 compatibilitytpavelchak2019-10-251-1/+1
|
* Remove tabs, and add conf filelwhite2018-02-192-12/+14
|
* Add config flags for the scheduler and routerlwhite2018-02-192-0/+23
|
* Revert "Backport 0.4 handling of workers after death"jason2017-08-181-1/+1
| | | | | | | - This was a stab at a fix which didn't fix the issue we were seeing. It's possible that it caused a memory issue so it is being reverted. This reverts commit 56cfa885b92b024dc2f70157a0f0b7826ad23e5b.
* Backport 0.4 handling of workers after deathDavid Hurst2017-08-111-1/+1
|
* add jobs in flight tracking and pdb handlingDavid Hurst2017-04-191-1/+1
|
* backport name cli arg to jobmanagerjason2017-04-181-2/+7
|
* add hostname to jobmanager's nameDavid Hurst2017-04-171-1/+1
|
* Finish better worker PRsideshowdave72017-04-031-13/+14
|
* version bump to 0.3.4sideshowdave72017-04-031-8/+12
|
* create a better interface between worker and jobmanagersideshowdave72017-03-311-2/+2
|
* fixup some worker logicsideshowdave72017-03-311-7/+7
|
* Implement pre/post hook supportsideshowdave72017-03-081-1/+1
|
* demo stuffsideshowdave72017-02-102-11/+3
|
* Update the pep8 goodness and test with circle and flake8jason2017-01-241-1/+1
|
* add missing commit to fix health check bugsideshowdave72017-01-181-1/+2
|
* Merge mastersideshowdave72017-01-041-5/+5
|\
| * cleanup and testssideshowdave72016-12-211-2/+2
| |
| * Jobmanager Pool with timeoutssideshowdave72016-12-211-5/+5
| |
* | dummy subscriber and send_publish helpersideshowdave72017-01-041-7/+12
| |
* | Initial pubsubsideshowdave72016-12-162-0/+27
|/
* Moved commands to same place as other admin commands, added testsUmair Naveed2016-11-041-1/+17
|
* worker addr failoversideshowdave72016-10-171-12/+24
|
* Stub of emq-clijason2016-09-081-7/+26
| | | | - starts emq-cli and implements status for the router
* Beginning of emq-cli administrative tooljason2016-09-061-0/+120
|
* job latenciessideshowdave72016-06-131-0/+24
|
* More work for named queuesjason2016-05-241-4/+14
| | | | | | | | | | | | | | | - 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.
* Update the setup.py entry scripts with what is in bin/jason2016-05-033-0/+0
|
* named queuesjason2016-04-291-1/+37
|
* MAN-29 Create a better config system for eventmqsideshowdave72016-01-083-8/+3
|
* thingsjason2015-12-141-1/+1
| | | | | cleans up logs executes jobs
* handle queuing messages betterjason2015-12-072-0/+33
| | | | | | adds a basic way to send tasks to run to a worker adds a waiting message queue to store messages when all workers are busy
* fix to logging, send multiple messages to workersjason2015-12-042-2/+4
| | | | | | - 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
* schedulerjason2015-12-011-0/+8
|
* updates and thingsjason2015-11-191-0/+8
|
* updatesjason2015-11-181-0/+16