Gecko [ sachasauda.akalacademy.ac.in ]

Name	Size	Permission
__pycache__	[ DIR ]	drwxr-xr-x
__init__.py	0 B	-rw-r--r--
apache.py	19.06 KB	-rw-r--r--
apache_kafka.py	12.9 KB	-rw-r--r--
apache_zookeeper.py	6.26 KB	-rw-r--r--
bandwidth.py	21.3 KB	-rw-r--r--
cassandra.py	9.21 KB	-rw-r--r--
cert.py	2.78 KB	-rw-r--r--
couch.py	9.5 KB	-rw-r--r--
cpu_usage.py	33 KB	-rw-r--r--
dem_plugin.py	6.08 KB	-rw-r--r--
disk.py	16.48 KB	-rw-r--r--
docker.py	38.41 KB	-rw-r--r--
elasticsearch.py	2.83 KB	-rw-r--r--
entropy.py	900 B	-rw-r--r--
exim.py	1.01 KB	-rw-r--r--
file_presence.py	5 KB	-rw-r--r--
haproxy.py	13.37 KB	-rw-r--r--
io_stats.py	13.41 KB	-rw-r--r--
jboss.py	13.46 KB	-rw-r--r--
jmx.py	8.02 KB	-rw-r--r--
linux_logs.py	3.4 KB	-rw-r--r--
lm_sensors.py	2.51 KB	-rw-r--r--
logstash_forwarder.py	1.58 KB	-rw-r--r--
memcache.py	5.99 KB	-rw-r--r--
memory_usage.py	26.11 KB	-rw-r--r--
mongo.py	15.96 KB	-rw-r--r--
mysql.py	19.74 KB	-rw-r--r--
nagios.py	5.36 KB	-rw-r--r--
nginx.py	11.96 KB	-rw-r--r--
nodejs.py	6.29 KB	-rw-r--r--
ntp.py	1.98 KB	-rw-r--r--
opcache.py	2.26 KB	-rw-r--r--
oracle.py	15.15 KB	-rw-r--r--
package_upgrade.py	8.08 KB	-rw-r--r--
phpfpm.py	5.51 KB	-rw-r--r--
ping.py	2.45 KB	-rw-r--r--
postfix.py	1.98 KB	-rw-r--r--
postgresql.py	19.13 KB	-rw-r--r--
process.py	16.32 KB	-rw-r--r--
rabbitmq.py	19.33 KB	-rw-r--r--
redis.py	11.19 KB	-rw-r--r--
sendmail.py	2.39 KB	-rw-r--r--
sysctl.py	1.46 KB	-rw-r--r--
tcp.py	6.26 KB	-rw-r--r--
template.py	3.28 KB	-rw-r--r--
tomcat.py	6.79 KB	-rw-r--r--
tomcat_jmx.py	15.82 KB	-rw-r--r--
unbound_dns.py	4.54 KB	-rw-r--r--
uptime.py	3.46 KB	-rw-r--r--
users.py	1.09 KB	-rw-r--r--
uwsgi.py	4.57 KB	-rw-r--r--
varnish.py	4.79 KB	-rw-r--r--
weblogic.py	13.38 KB	-rw-r--r--
weblogic12c.py	18.75 KB	-rw-r--r--

Code Editor : varnish.py

import agent_util
import logging

logger = logging.getLogger(__name__)

def execute_query(query):
    ret, output = agent_util.execute_command(query)
    return str(output);

class VarnishPlugin(agent_util.Plugin):
    textkey = "varnish"
    label = "Varnish"

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

# check if varnish is even installed or running
        installed = agent_util.which("varnishd")
        if not installed:
            self.log.info("The varnishd binary was not found")
            status = agent_util.UNSUPPORTED
            msg = "varnish binary not found"
            return {}

stat_binary_path = agent_util.which("varnishstat")
        if not stat_binary_path:
            msg = "The varnishstat binary was not found."
            status = agent_util.MISCONFIGURED
            self.log.info(msg)

data = {
            "client_conn": {
                "label": "Client connections accepted",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "client_req": {
                "label": "Client requests received",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "cache_hit": {
                "label": "Cache hits",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "cache_hitpass": {
                "label": "Cache hits for pass",
                "options": None,
                "status": status,
                "error_message": msg
            },

"backend_fail": {
                "label": "Backend conn. failures",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "cache_miss": {
                "label": "Cache misses",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_object": {
                "label": "Nstruct object",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_wrk": {
                "label": "Nworker threads",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_wrk_create": {
                "label": "Nworker threads created",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_wrk_failed": {
                "label": "Nworker threads not created",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_wrk_max": {
                "label": "Nworker threads limited",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_wrk_drop": {
                "label": "Ndropped work requests",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_lru_nuked": {
                "label": "NLRU nuked objects",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "esi_errors": {
                "label": "ESI parse errors (unlock)",
                "options": None,
                "status": status,
                "error_message": msg
            },
            "n_expired": {
                "label": "Nexpired objects",
                "options": None,
                "status": status,
                "error_message": msg
            },
        }
        if "extended_metrics" in config:
            extended_metrics = [m.strip().lower() for m in config["extended_metrics"].split(',')]
            for m in extended_metrics:
                data["extended_metric.%s" % m] = {
                    "label": "Varnish %s" % m.replace('_', " "),
                    "options": None,
                    "status": status,
                    "error_message": msg
                }
        return data

def check(self, textkey, data, config):
        stat_binary_path = agent_util.which("varnishstat")
        query = '%s -1 -f %s'
        if "extended_metric" in textkey:
            result = execute_query(query % (stat_binary_path, textkey.replace("extended_metric.", "")))
        else:
            result = execute_query(query % (stat_binary_path, textkey))
        fields = result.split()
        try:
            return int(fields[1])
        except:
            return 0
            self.log.debug("%s: %s" % (textkey.replace("extended_metric.", "").title(), str(result)))

${this.title}

Code Editor : varnish.py