aboutsummaryrefslogtreecommitdiffstats
Commit message (Collapse)AuthorAgeFilesLines
* Refactor eventmq configuration managementfeature/config_refactorjason2017-03-2815-170/+265
| | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | - Refactor each device's configuration loading. The global section will be loaded then the section for the app will overrite any sections. - Defines ambiguous settings that cannot be defined globally. skip these settings and emit a warning if they are - update eventmq.conf-dist to include comments and more of the settings that can be defined. - Refactor some option names. * Job Manager: `WORKER_ADDR` is now `CONNECT_ADDR` in the `[jobmanager]` section * Job Manager: `WORKER_ADDR_DEFAULT` is now `CONNECT_ADDR_DEFAULT` in the `[jobmanager]` section * Job Manager: `WORKER_ADDR_FAILOVER` is now `CONNECT_ADDR_FAILOVER` in the `[jobmanager]` section * Publisher: `PUBLISHER_FRONTEND_ADDR` is not `FRONTEND_LISTEN_ADDR` in the `[publisher]` section * Publisher: `PUBLISHER_BACKEND_ADDR` is not `BACKEND_LISTEN_ADDR` in the `[publisher]` section * Router: `FRONTEND_ADDR` is now `FRONTEND_LISTEN_ADDR` in the `[router]` section * Router: `BACKEND_ADDR` is now `BACKEND_LISTEN_ADDR` in the `[router]` section * Scheduler: `SCHEDULER_ADDR` is now `CONNECT_ADDR` in the `[scheduler]` section * `RQ_HOST` is now `REDIS_HOST` * `RQ_PORT` is now `REDIS_PORT` * `RQ_DB` is now `REDIS_DB` * `RQ_PASSWORD` is now `REDIS_PASSWORD` * `ADMINISTRATIVE_ADDR` is now `ADMINISTRATIVE_LISTEN_ADDR` in each respective section See also: #20
* Refactor settings.py testsjason2017-03-223-104/+191
| | | | | | | | | - Split large test into smaller tests - Add test for invalid json - Add test for non-nested json array - Add context manager for mocking the config file. Related: #20, TEEM-2275 #comment refactored settings.py tests
* Rename incoming and outgoing ports to frontend and backendjason2017-03-2112-98/+101
| | | | | | | | | - This refactors the `self.incoming` and `self.outgoing` sockets to `self.frontend` (client facing) and `self.backend` (manager facing). This change should make the purpose of these ports more clear for new people working in the code. Resolves: #16
* Add license header to scrips in bin/jason2017-03-023-2/+30
| | | | | - The GPL header was missing from emq-router and emq-scheduler. - Reorder the imports in emq-jobmanager to follow the standard.
* Rename`emq-pubsub` to `emq-publisher`jason2017-03-021-0/+0
| | | | | - Rename the emq-pubsub entry point script to emq-publisher to follow the naming standard.
* Merge branch 'master' into 0.4jason2017-02-200-0/+0
|\
| * Merge pull request #5 from eventmq/0.3jason2017-02-2010-83/+190
| |\ | | | | | | 0.3
| | * Merge pull request #4 from com4/feature/schedule_helpers0.3.1jason2017-02-2010-83/+190
| | |\ | |/ / | | | Add schedule and unschedule helper functions (emq 0.3.1)
| | * Update badge, doc URLs. Add IRC channel infojason2017-02-172-40/+8
| | |
* | | Merge branch 'feature/schedule_helpers' into 0.4jason2017-02-1712-43/+60
|\ \ \
| * | | Update badge, doc URLs. Add IRC channel infojason2017-02-172-39/+8
| | |/ | |/|
| * | Version bump 0.3.1. Update URL.jason2017-02-172-4/+6
| | |
| * | Remove `caller_id` requirement for scheduled jobsjason2017-02-176-74/+98
| | | | | | | | | | | | | | | | | | | | | | | | | | | - Serializes full argument list for messages and hashes that to uniquely identify jobs (fixes #73) - Removes unused `raw_jobs` part of code in `load_jobs` - Removes unused `cron_hash` method - Adds `connect` statements to the schedule/unschedule helper functions - Adds coveralls for coverage reporting to circle.yml
| * | Add schedule and unschedule helper functionsjason2017-02-174-3/+116
| |/ | | | | | | - These functions will create the socket for the user
| * Merge branch 'master' of github.com:enderlabs/eventmq0.3jason2017-02-159-31/+42
| |\
| | * Merge pull request #80 from sideshowdave7/masterjason2017-02-149-31/+42
| | |\ | | | | | | | | EventMQ 0.3
| | | * fix import locationsideshowdave72017-02-141-2/+1
| | | |
| | | * remove now uncalled funcs from mock in test_jobmanagersideshowdave72017-02-141-10/+1
| | | |
| | | * formattingsideshowdave72017-02-144-5/+2
| | | |
| | | * tag v 0.3sideshowdave72017-02-142-2/+2
| | | |
| | | * demo stuffsideshowdave72017-02-108-18/+42
| | |/
| * | Update config for settingsjason2017-02-151-5/+6
| |/
* | Update PyZMQ to 16.0.2 for EventMQ 0.4jason2017-01-311-1/+1
| |
* | Use SHA-1 instead of python's built-in hash() function for schedule_hashjason2017-01-312-5/+6
| | | | | | | | | | | | - Python's builtin hash() function uses a random seed to prevent 'tar-pitting' an application by setting keys designed to collide. See: http://www.ocert.org/advisories/ocert-2011-003.html
* | Remove `caller_id` requirement for scheduled jobsjason2017-01-316-74/+98
| | | | | | | | | | | | | | | | | | - Serializes full argument list for messages and hashes that to uniquely identify jobs (fixes #73) - Removes unused `raw_jobs` part of code in `load_jobs` - Removes unused `cron_hash` method - Adds `connect` statements to the schedule/unschedule helper functions - Adds coveralls for coverage reporting to circle.yml
* | Add schedule and unschedule helper functionsjason2017-01-314-3/+116
|/ | | | - These functions will create the socket for the user
* Update README with coveralls test coverage % badgejason2017-01-311-0/+1
|
* Update circle.yml to report coverage to coverallsjason2017-01-311-3/+7
|
* Update README with mailing list linksjason2017-01-311-2/+7
|
* Merge pull request #79 from sideshowdave7/masterjason2017-01-304-3/+8
|\ | | | | Scheduled jobs to send reply-requested header
| * version bumpsideshowdave72017-01-302-2/+2
| |
| * scheduled messages should always ask for a reply for job latency tracking; ↵sideshowdave72017-01-302-1/+6
|/ | | | join on workers when the jobmanager dies or quits
* Merge branch 'master' of github.com:enderlabs/eventmqjason2017-01-2532-164/+151
|\
| * Merge pull request #77 from com4/pep8-enforcementjason2017-01-2532-164/+151
| |\ | | | | | | Update the pep8 goodness and test with circle and flake8
| | * Update the pep8 goodness and test with circle and flake8jason2017-01-2432-164/+151
| |/
* | Bump version to 0.3-rc9jason2017-01-252-2/+2
|/
* Merge pull request #74 from com4/fix-hastiness-of-scheduled-jobs0.3-rc9David Hurst2017-01-231-5/+8
|\ | | | | Immediatly run jobs which have not specified 'nohaste'
| * Immediatly run jobs which have not specified 'nohaste'jason2017-01-191-5/+8
| |
* | Merge pull request #75 from sideshowdave7/master0.3-rc8jason2017-01-223-3/+9
|\ \ | |/ |/| ZMQError is thrown when we are polling and its rudely interrupted, ha…
| * ZMQError is thrown when we are polling and its rudely interrupted, handle itsideshowdave72017-01-203-3/+9
|/
* Merge pull request #72 from sideshowdave7/master0.3-rc7David Hurst2017-01-184-4/+8
|\ | | | | Block on request queue before exiting
| * version bumpsideshowdave72017-01-183-3/+3
| |
| * close request queue and block until its flushedsideshowdave72017-01-181-1/+4
| |
| * prevent crash before any workers connect and we send something to default queuesideshowdave72017-01-183-3/+4
| |
* | Merge pull request #70 from sideshowdave7/masterDavid Hurst2017-01-187-39/+39
|\ \ | |/ | | EventMQ 0.3rc5 (We'll get 0.3 someday) Fix critical worker health check bug, Simplify scheduler run_count header (remove support for persistance)
| * add missing commit to fix health check bugsideshowdave72017-01-182-4/+6
| |
| * move MAX_JOB_COUNT setting to global confsideshowdave72017-01-182-5/+4
| |
| * version bumpsideshowdave72017-01-182-2/+2
| |
| * implement a MAX_JOB_COUNT to prevent memory creepsideshowdave72017-01-182-1/+13
| |
| * scheduler edge case fixessideshowdave72017-01-161-34/+20
| |
generated by cgit v1.2.1 (git 2.18.0) at 2026-01-12 12:44:53 +0000