003 File Manager
Current Path:
/usr/local/lib/python3.8/site-packages/salt/engines
usr
/
local
/
lib
/
python3.8
/
site-packages
/
salt
/
engines
/
📁
..
📄
__init__.py
(3.62 KB)
📁
__pycache__
📄
docker_events.py
(2.84 KB)
📄
fluent.py
(2.05 KB)
📄
http_logstash.py
(2.84 KB)
📄
ircbot.py
(10.22 KB)
📄
junos_syslog.py
(13.18 KB)
📄
libvirt_events.py
(21.28 KB)
📄
logentries.py
(5.64 KB)
📄
logstash_engine.py
(1.77 KB)
📄
napalm_syslog.py
(11.59 KB)
📄
reactor.py
(720 B)
📄
redis_sentinel.py
(2.88 KB)
📄
script.py
(3.33 KB)
📄
slack.py
(35.79 KB)
📄
sqs_events.py
(4.65 KB)
📄
stalekey.py
(3.67 KB)
📄
test.py
(932 B)
📄
thorium.py
(314 B)
📄
webhook.py
(2.78 KB)
Editing: test.py
""" A simple test engine, not intended for real use but as an example """ import logging import salt.utils.event import salt.utils.json log = logging.getLogger(__name__) def event_bus_context(opts): if opts["__role"] == "master": event_bus = salt.utils.event.get_master_event( opts, opts["sock_dir"], listen=True ) else: event_bus = salt.utils.event.get_event( "minion", transport=opts["transport"], opts=opts, sock_dir=opts["sock_dir"], listen=True, ) log.debug("test engine started") return event_bus def start(): """ Listen to events and write them to a log file """ with event_bus_context(__opts__) as event_bus: while True: event = event_bus.get_event() jevent = salt.utils.json.dumps(event) if event: log.debug(jevent)
Upload File
Create Folder