MySql

Complexity

Total Complexity

3

Size/Duplication

Total Lines	47
Duplicated Lines	31.91 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	poll()	0	13	2
A	__init__()	15	15	1

# -*- coding: utf-8 -*-

__author__ = 'Kenny Freeman'
__email__ = 'kenny.freeman@gmail.com'
__license__ = "ISCL"
__docformat__ = 'reStructuredText'

import time
from collections import deque

import pymysql # not listed in setup.py requirements - you must install this

import plumd
import plumd.plugins
from plumd.calc import Differential
from plumd.util import Filter


"""
KEY_CACHES
INFORMATION_SCHEMA
TABLES                       # or show table status - not accurate for innodb
INNODB_TRX
INNODB_BUFFER_POOL_STATS
TP_THREAD_STATE              # thread_handling=pool-of-threads in /etc/my.cnf
"""


class MySql(plumd.plugins.Reader):
    """Plugin to measure various MySQL metrics."""
    defaults = {
        'poll.interval': 10,
        'mysql_hosts': {
            'local': {
                'host': '127.0.0.1',
                'port': 3306,
                'user': 'monitor',
                'pass': 'monitor',
                'dbs': ['mysql']
            }
        },
        'mysql_gauges': {},
        'mysql_rates': {}
    }

    def __init__(self, log, config):

This code seems to be duplicated in your project.

        """Plugin to measure various MySQL metrics.

        :param log: A logger
        :type log: logging.RootLogger
        :param config: a plumd.config.Conf configuration helper instance.
        :type config: plumd.config.Conf
        """
        super(MySql, self).__init__(log, config)
        self.config.defaults(MySql.defaults)
        self.calc = Differential()
        self.hosts = self.config.get('mysql_hosts')
        self.filter = Filter()
        self.gauges = self.config.get('mysql_gauges')
        self.rates = self.config.get('mysql_rates')


    def poll(self):
        """Poll for MySQL metrics.

        :rtype: ResultSet
        """
        result = plumd.Result("mysql")

        # iterate through each configured host
        for hname, hconf in self.hosts.items():
            # show status for general metrics
            pass

        return [result]