Gecko [ lostrivercommunitycenter.com ]

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2026-09-15 02:50
__init__.py	0 B	-rw-r--r--	2026-09-14 20:04
apache.py	20.07 KB	-rw-r--r--	2026-09-14 20:04
apache_kafka.py	13.66 KB	-rw-r--r--	2026-09-14 20:04
apache_zookeeper.py	6.34 KB	-rw-r--r--	2026-09-14 20:04
bandwidth.py	22.59 KB	-rw-r--r--	2026-09-14 20:04
cassandra.py	9.46 KB	-rw-r--r--	2026-09-14 20:04
cert.py	2.89 KB	-rw-r--r--	2026-09-14 20:04
couch.py	9.56 KB	-rw-r--r--	2026-09-14 20:04
cpu_usage.py	32.09 KB	-rw-r--r--	2026-09-14 20:04
dem_plugin.py	7.48 KB	-rw-r--r--	2026-09-14 20:04
disk.py	16.8 KB	-rw-r--r--	2026-09-14 20:04
docker.py	38.95 KB	-rw-r--r--	2026-09-14 20:04
elasticsearch.py	2.9 KB	-rw-r--r--	2026-09-14 20:04
entropy.py	930 B	-rw-r--r--	2026-09-14 20:04
exim.py	1 KB	-rw-r--r--	2026-09-14 20:04
file_presence.py	5.07 KB	-rw-r--r--	2026-09-14 20:04
fortisase_connection.py	6.99 KB	-rw-r--r--	2026-09-14 20:04
haproxy.py	13.46 KB	-rw-r--r--	2026-09-14 20:04
io_stats.py	13.39 KB	-rw-r--r--	2026-09-14 20:04
jboss.py	13.66 KB	-rw-r--r--	2026-09-14 20:04
jmx.py	8.39 KB	-rw-r--r--	2026-09-14 20:04
linux_logs.py	3.34 KB	-rw-r--r--	2026-09-14 20:04
lm_sensors.py	2.54 KB	-rw-r--r--	2026-09-14 20:04
logstash_forwarder.py	1.64 KB	-rw-r--r--	2026-09-14 20:04
memcache.py	6.04 KB	-rw-r--r--	2026-09-14 20:04
memory_usage.py	26.56 KB	-rw-r--r--	2026-09-14 20:04
mongo.py	16.61 KB	-rw-r--r--	2026-09-14 20:04
mysql.py	20.4 KB	-rw-r--r--	2026-09-14 20:04
nagios.py	5.58 KB	-rw-r--r--	2026-09-14 20:04
nginx.py	12.33 KB	-rw-r--r--	2026-09-14 20:04
nodejs.py	6.44 KB	-rw-r--r--	2026-09-14 20:04
ntp.py	1.98 KB	-rw-r--r--	2026-09-14 20:04
opcache.py	2.3 KB	-rw-r--r--	2026-09-14 20:04
oracle.py	15.6 KB	-rw-r--r--	2026-09-14 20:04
package_upgrade.py	8.88 KB	-rw-r--r--	2026-09-14 20:04
phpfpm.py	5.61 KB	-rw-r--r--	2026-09-14 20:04
ping.py	2.6 KB	-rw-r--r--	2026-09-14 20:04
postfix.py	1.99 KB	-rw-r--r--	2026-09-14 20:04
postgresql.py	21.37 KB	-rw-r--r--	2026-09-14 20:04
process.py	17.23 KB	-rw-r--r--	2026-09-14 20:04
rabbitmq.py	19.85 KB	-rw-r--r--	2026-09-14 20:04
redis.py	11.31 KB	-rw-r--r--	2026-09-14 20:04
sendmail.py	2.42 KB	-rw-r--r--	2026-09-14 20:04
sysctl.py	1.42 KB	-rw-r--r--	2026-09-14 20:04
tcp.py	6.59 KB	-rw-r--r--	2026-09-14 20:04
template.py	3.28 KB	-rw-r--r--	2026-09-14 20:04
tomcat.py	7.09 KB	-rw-r--r--	2026-09-14 20:04
tomcat_jmx.py	19.11 KB	-rw-r--r--	2026-09-14 20:04
unbound_dns.py	4.62 KB	-rw-r--r--	2026-09-14 20:04
uptime.py	3.61 KB	-rw-r--r--	2026-09-14 20:04
users.py	1.09 KB	-rw-r--r--	2026-09-14 20:04
uwsgi.py	4.73 KB	-rw-r--r--	2026-09-14 20:04
varnish.py	4.91 KB	-rw-r--r--	2026-09-14 20:04
weblogic.py	13.84 KB	-rw-r--r--	2026-09-14 20:04
weblogic12c.py	19.2 KB	-rw-r--r--	2026-09-14 20:04

Rename

# -*- coding: utf-8 -*-
import agent_util
import logging
from glob import glob
from library.log_matcher import LogMatcher

class LinuxLogsPlugin(agent_util.Plugin):
    textkey = "linux_log"
    label = "Event log"

@classmethod
    def get_metadata(self, config):
        data = {
            "count": {
                "label": "Event entry count",
                "options": None,
                "status": agent_util.SUPPORTED,
                "error_message": None,
                "unit": "count",
                "option_string": True,
            }
        }
        return data

def check(self, textkey, data, config={}):
        # Passed data from the check schedule
        log_source = data.get("log_source")
        timescale = data.get("timescale")
        expression = data.get("filter")
        log_source = log_source.strip(" ")

if "*" in log_source or "?" in log_source:
            # Handle multiple files
            files = glob(log_source)
        else:
            files = [log_source]

file_inodes = {}
        total_metrics = 0

expression = expression or "*"
        expression = expression.replace("*", ".*")
        expression = expression.replace('""', ".*")
        for target in files:
            # Extract the file current inode
            try:
                file_inodes[target] = LogMatcher.get_file_inode(target)
            except OSError:
                import sys

_, error, _ = sys.exc_info()
                logging.error("Error opening %s file." % (target))
                logging.error(error)
                continue

# Extract data from the agent cache about the check
            log_data = self.get_cache_results(
                textkey, "%s/%s" % (self.schedule.id, target)
            )
            if log_data:
                log_data = log_data[0][-1]
            else:
                log_data = dict()

last_line_number = log_data.get("last_known_line")
            stored_inode = log_data.get("inode")
            results = log_data.get("results", [])

# Extract the lines of the file.
            try:
                total_lines, current_lines = LogMatcher.get_file_lines(
                    last_line_number, target, file_inodes[target], stored_inode
                )
            except IOError:
                import sys

_, e, _ = sys.exc_info()
                logging.error("Could not open file: %s" % str(e))
                return None

logging.info(
                "Stored line %s Current line %s Looking at %s lines"
                % (str(last_line_number), str(total_lines), str(len(current_lines)))
            )
            # Perform the matching of the expression in the lines
            log_matcher = LogMatcher(stored_inode)
            results = log_matcher.match(current_lines, expression)
            metric, results = log_matcher.calculate_metric(results, timescale)
            total_metrics += metric and metric or 0

cache_data = dict(
                inode=file_inodes[target], last_known_line=total_lines, results=results
            )
            self.cache_result(textkey, "%s/%s" % (self.schedule.id, target), cache_data)
            logging.info(
                'Found %s instances of "%s" in %s'
                % (str(metric or 0), expression, target)
            )
        return total_metrics