Add consumer to Kafka bootstep and add signal + handler to respond to received
Kafka messages
Showing
- CHANGES.rst 2 additions, 0 deletionsCHANGES.rst
- doc/configuration.rst 23 additions, 0 deletionsdoc/configuration.rst
- gwcelery/conf/__init__.py 10 additions, 0 deletionsgwcelery/conf/__init__.py
- gwcelery/conf/production.py 10 additions, 0 deletionsgwcelery/conf/production.py
- gwcelery/kafka/__init__.py 2 additions, 2 deletionsgwcelery/kafka/__init__.py
- gwcelery/kafka/bootsteps.py 130 additions, 25 deletionsgwcelery/kafka/bootsteps.py
- gwcelery/kafka/signals.py 17 additions, 0 deletionsgwcelery/kafka/signals.py
- gwcelery/tasks/alerts.py 40 additions, 2 deletionsgwcelery/tasks/alerts.py
- gwcelery/tests/test_tools_nagios.py 35 additions, 1 deletiongwcelery/tests/test_tools_nagios.py
- gwcelery/tools/nagios.py 21 additions, 0 deletionsgwcelery/tools/nagios.py
- poetry.lock 13 additions, 1 deletionpoetry.lock
- pyproject.toml 1 addition, 0 deletionspyproject.toml
Loading
Please register or sign in to comment