Gecko [ goons4good.org ]

Linux server.edchosting.com 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64
LiteSpeed
Server IP : 75.98.162.185 & Your IP : 216.73.216.163
Domains : Cant Read [ /etc/named.conf ]
User : goons4good

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2022-10-11 05:09
__init__.py	3.62 KB	-rw-r--r--	2022-05-16 09:16
docker_events.py	2.84 KB	-rw-r--r--	2022-05-16 09:16
fluent.py	2.05 KB	-rw-r--r--	2022-05-16 09:16
http_logstash.py	2.84 KB	-rw-r--r--	2022-05-16 09:16
ircbot.py	10.22 KB	-rw-r--r--	2022-05-16 09:16
junos_syslog.py	13.18 KB	-rw-r--r--	2022-05-16 09:16
libvirt_events.py	21.28 KB	-rw-r--r--	2022-05-16 09:16
logentries.py	5.64 KB	-rw-r--r--	2022-05-16 09:16
logstash_engine.py	1.77 KB	-rw-r--r--	2022-05-16 09:16
napalm_syslog.py	11.59 KB	-rw-r--r--	2022-05-16 09:16
reactor.py	720 B	-rw-r--r--	2022-05-16 09:16
redis_sentinel.py	2.88 KB	-rw-r--r--	2022-05-16 09:16
script.py	3.33 KB	-rw-r--r--	2022-05-16 09:16
slack.py	35.79 KB	-rw-r--r--	2022-05-16 09:16
sqs_events.py	4.65 KB	-rw-r--r--	2022-05-16 09:16
stalekey.py	3.67 KB	-rw-r--r--	2022-05-16 09:16
test.py	932 B	-rw-r--r--	2022-05-16 09:16
thorium.py	314 B	-rw-r--r--	2022-05-16 09:16
webhook.py	2.78 KB	-rw-r--r--	2022-05-16 09:16

Rename

"""
An engine that reads messages from the salt event bus and pushes
them onto a logstash endpoint.

.. versionadded:: 2015.8.0

:configuration:

Example configuration

.. code-block:: yaml

engines:
          - logstash:
              host: log.my_network.com
              port: 5959
              proto: tcp

:depends: logstash
"""

import logging

import salt.utils.event

try:
    import logstash
except ImportError:
    logstash = None

log = logging.getLogger(__name__)

__virtualname__ = "logstash"

def __virtual__():
    return (
        __virtualname__
        if logstash is not None
        else (False, "python-logstash not installed")
    )

def event_bus_context(opts):
    if opts.get("id").endswith("_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,
        )
    return event_bus

def start(host, port=5959, tag="salt/engine/logstash", proto="udp"):
    """
    Listen to salt events and forward them to logstash
    """

if proto == "tcp":
        logstashHandler = logstash.TCPLogstashHandler
    elif proto == "udp":
        logstashHandler = logstash.UDPLogstashHandler

logstash_logger = logging.getLogger("python-logstash-logger")
    logstash_logger.setLevel(logging.INFO)
    logstash_logger.addHandler(logstashHandler(host, port, version=1))

with event_bus_context(__opts__) as event_bus:
        log.debug("Logstash engine started")
        while True:
            event = event_bus.get_event()
            if event:
                logstash_logger.info(tag, extra=event)