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

import agent_util
import sys
import socket
import traceback

def netcat(hostname, port, content):
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((hostname, port))
    s.sendall(content)
    s.shutdown(socket.SHUT_WR)
    while 1:
        data = s.recv(1024)
        if data == "":
            break
        response = data
        break
    s.close()
    return response

def nc_to_dict(data):
    parsed = {}
    a = data.split("\n")
    for l in a:
        try:
            b = l.split("\t")
            parsed[b[0]] = b[1]
        except:
            continue
    return parsed

class ApacheZookeeperPlugin(agent_util.Plugin):
    textkey = "apache_zookeeper"
    label = "Apache Zookeeper"

@classmethod
    def get_metadata(self, config):
        status = agent_util.SUPPORTED
        msg = None

if status == agent_util.SUPPORTED and (
            not "host" in config or not "port" in config
        ):
            msg = "The host and port entries were not found in the [apache_zookeeper] block in the agent config file."
            self.log.info(msg)
            status = agent_util.MISCONFIGURED
            return {}

if status == agent_util.SUPPORTED:
            response = None
            try:
                response = netcat(config["host"], int(config["port"]), "envi")
            except:
                self.log.exception("Error running Zookeeper hello")
                self.log.debug(traceback.format_exc())
                status = agent_util.MISCONFIGURED
                msg = ""
                return {}
            if response is None or response == "":
                self.log.exception("Bad response running Zookeeper hello")
                return {}

data = {
            # basic
            "avg_latency": {
                "label": "Average request latency",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "ms",
            },
            "max_latency": {
                "label": "Maximum request latency",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "ms",
            },
            "packets_received": {
                "label": "Packets received",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "packets",
            },
            "packets_sent": {
                "label": "Packets sent",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "packets",
            },
            "packets_received_per_sec": {
                "label": "Packets received/sec",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "packets/sec",
            },
            "packets_sent_per_sec": {
                "label": "Packets sent/sec",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "packets/sec",
            },
            "outstanding_requests": {
                "label": "Outstanding Requests",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "",
            },
            "server_state": {
                "label": "Server Mode",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "",
            },
            "znode_count": {
                "label": "Node count",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "",
            },
            "watch_count": {
                "label": "Watcher Count",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "",
            },
            "approximate_data_size": {
                "label": "Approximate data size",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "bytes",
            },
            "open_file_descriptor_count": {
                "label": "Open file descriptors",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "files",
            },
            "fsync_threshold_exceed_count": {
                "label": "Slow fsync count",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "",
            },
            "ruok": {
                "label": "Node error state",
                "options": None,
                "status": status,
                "error_message": msg,
                "unit": "",
            },
        }

return data

def check(self, textkey, data, config):
        if textkey == "ruok":
            output = netcat(config["host"], int(config["port"]), "ruok")
            if output == "imok":
                return 0
            else:
                return 1
        else:
            output = netcat(config["host"], int(config["port"]), "mntr")
            data = nc_to_dict(output)
            key = "zk_" + str(textkey.replace("_per_sec", ""))
            value = data.get(key, False)

if textkey == "server_state":
                if value == "follower":
                    return 0
                if value == "leader":
                    return 1
            if (
                textkey == "packets_received_per_sec"
                or textkey == "packets_sent_per_sec"
            ):
                self.log.debug(data)
                if value > 0:
                    cached = self.get_cache_results(textkey, None)
                    self.cache_result(textkey, None, value, replace=True)
                    self.log.debug("####\nGot cached result!\n%s" % cached)
                    print("####\nGot cached result!\n%s" % cached)
                    delta, c = cached[0]
                    rate = (float(value) / float(c)) / float(delta)
                    return rate
                else:
                    return 0
            if value:
                return float(value)
            else:
                return None