Gecko [ waterstats.dev.bestseocompanymiami.com ]

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

Code Editor : phpfpm.py

import agent_util
import logging
from agent_util import float

try:
    # Python 2.x
    import httplib
except:
    import http.client as httplib
try:
    # Python 2.x
    import urlparse
except:
    import urllib.parse as urlpars

logger = logging.getLogger(__name__)

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

class PHPFPMPlugin(agent_util.Plugin):
    textkey = "phpfpm"
    label = "PHP-FPM"

@classmethod
    def get_metadata(self, config):
        # Installation and config checks
        installed = agent_util.which("php5-fpm") or agent_util.which("php-fpm")
        configured = "console_url" in config

# if config is present, trust it and proceed
        if configured:
            self.log.info("console_url found in config. Marking plugin as supported")
            status = agent_util.SUPPORTED
            msg = None

# PHP-FPM is installed, but not configured, ask the user for more config assistance
        elif installed and not configured:
            self.log.info("PHP FPM binary found, but console_url is not in config")
            status = agent_util.MISCONFIGURED
            msg = "console_url is not in config"
            return {}

# PHP-FPM does not appear to be installed and no config provided, disqualify the plugin
        else:
            self.log.info("No console_url provided and php-fpm binary not found")
            status = agent_util.UNSUPPORTED
            msg = "php-fpm binary not found"
            return {}

# Generate options based on the number of entries in the config file.
        options = config.get("console_url").split(",")

self.log.info("PHP-FPM is supported. Generating Metadata.")

# This is the metadata for the plugin.

data = {
            "active processes": {
                "label": "Active processes",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "idle processes": {
                "label": "Idle processes",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "listen queue": {
                "label": "Listen queue",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "listen queue len": {
                "label": "Listen queue len",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "max active processes": {
                "label": "Max active processes",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "max children reached": {
                "label": "Children reached",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "max listen queue": {
                "label": "Max listen queue",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "slow requests": {
                "label": "Slow Requests",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "start since": {
                "label": "Start since",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "start time": {
                "label": "Start time",
                "options": options,
                "status": status,
                "error_message": msg,
            },
            "total processes": {
                "label": "Total Processes",
                "options": options,
                "status": status,
                "error_message": msg,
            },
        }

return data

def check(self, textkey, data, config):
        """
        Make a GET request to the console url and parse the output.
        """
        if data.startswith("http"):
            url = urlparse.urlparse(data + "?json&full")
            if data.startswith("https:"):
                connection = httplib.HTTPSConnection(host=url.netloc, timeout=25)
            else:
                connection = httplib.HTTPConnection(host=url.netloc, timeout=25)
            connection.request("GET", "%s?%s" % (url.path, url.query))
            resp = connection.getresponse()
            if int(resp.status) != 200:
                logging.error(
                    "Invalid response from %s/%s Reason: %s"
                    % (url.netloc, url.path, resp.reason)
                )
                return
            else:
                output = resp.read().decode("utf-8")
            connection.close()
        else:
            query = (
                r"SCRIPT_NAME=/status SCRIPT_FILENAME=/status QUERY_STRING=json\&full REQUEST_METHOD=GET cgi-fcgi -bind -connect "
                + data
                + " |tail -1"
            )
            ret, output = agent_util.execute_command(query)
        try:
            statLines = agent_util.json_loads(output)
        except Exception:
            logging.exception("Unable to parse json output.")
            return
        metric = str(textkey).replace("_", " ")
        if statLines.has_key(metric):
            return float(statLines[metric])

else:
            raise Exception(
                "stats output did not contain metric "
                + metric
                + ". stats output: "
                + statLines
            )

${this.title}

Code Editor : phpfpm.py