Proc

Complexity

Total Complexity

5

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Importance

Changes	6
Bugs	2	Features	2

2 Methods

Rating	Name	Duplication	Size	Complexity
A	poll()	0	13	2
A	__init__()	0	19	3

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

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

from collections import deque

import plumd
import plumd.plugins

from plumd.plugins.readers.linux.proc.conntrack import Conntrack
from plumd.plugins.readers.linux.proc.diskstats import DiskStats
from plumd.plugins.readers.linux.proc.loadavg import LoadAverage
from plumd.plugins.readers.linux.proc.mem import Mem
from plumd.plugins.readers.linux.proc.netdev import NetDev
from plumd.plugins.readers.linux.proc.netsnmp import NetSnmp
from plumd.plugins.readers.linux.proc.netstat import Netstat
from plumd.plugins.readers.linux.proc.sockstat import SockStat
from plumd.plugins.readers.linux.proc.stat import Stat
from plumd.plugins.readers.linux.proc.swap import Swap
from plumd.plugins.readers.linux.proc.uptime import Uptime


classes = [Conntrack, DiskStats, LoadAverage, Mem, NetDev, NetSnmp, Netstat,
           SockStat, Stat, Swap, Uptime]


class Proc(plumd.plugins.Reader):
    """Plugin to measure various kernel metrics from /proc."""
    defaults = {
        'poll.interval': 10,
        'disabled_readers': []
    }

    def __init__(self, log, config):
        """Plugin to measure various kernel metrics from /proc.

        :param log: A logger
        :type log: logging.RootLogger
        :param config: a plumd.config.Conf configuration helper instance.
        :type config: plumd.config.Conf
        """
        super(Proc, self).__init__(log, config)
        config.defaults(Proc.defaults)
        self.readers = deque()
        disabled = config.get('disabled_readers')
        for cls in classes:
            if cls.__name__ in disabled:
                msg = "Proc: skipping disabled reader: {0}"
                self.log.warn(msg.format(cls.__name__))
                continue
            self.log.debug("Proc: initializing reader: {0}".format(cls.__name__))
            self.readers.append(cls(log, config))


    def poll(self):
        """Poll for kernel metrics under /proc.

        :rtype: ResultSet
        """
        ret = plumd.ResultSet([])
        for rdr in self.readers:
            #self.log.debug("Proc: calling {0}".format(rdr.__class__.__name__))
            metrics = rdr.check()
            msg = "Proc: {0} returned: {1}"
            #self.log.debug(msg.format(rdr.__class__.__name__, metrics))
            ret.add_list(metrics)
        return ret