salt/engines/reactor.py
# -*- coding: utf-8 -*-
'''
Setup Reactor
Example Config in Master or Minion config
.. code-block:: yaml
engines:
- reactor:
refresh_interval: 60
worker_threads: 10
worker_hwm: 10000
reactor:
- 'salt/cloud/*/destroyed':
- /srv/reactor/destroy/*.sls
'''
# Import Python libs
from __future__ import absolute_import, print_function, unicode_literals
# Import salt libs
import salt.utils.reactor
def start(refresh_interval=None, worker_threads=None, worker_hwm=None):
if refresh_interval is not None:
__opts__['reactor_refresh_interval'] = refresh_interval
if worker_threads is not None:
__opts__['reactor_worker_threads'] = worker_threads
if worker_hwm is not None:
__opts__['reactor_worker_hwm'] = worker_hwm
salt.utils.reactor.Reactor(__opts__).run()