ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / local / lib / python3.9 / site-packages / agent360 / plugins

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import pickle
import time
import sys
if sys.version_info >= (3,):
    import configparser
else:
    import ConfigParser

class BasePlugin:
    '''
    Abstract class for plugins
    '''
    __name__ = ''

def __init__(self, agent_cache=[]):
        if isinstance(agent_cache, list):
            self.agent_cache = agent_cache
        else:
            raise TypeError('Type of agent_cache have to be list')

# if not self.__name__:
        #     self.__name__ = os.path.splitext(os.path.basename(__file__))[0]

def run(self, config=None):
        '''
        Virtual method for running the plugin
        '''
        pass

def execute(self):
        '''
        Execution wrapper for the plugin
        argv[1]: ini_file
        '''
        config = None
        if len(sys.argv) > 1:
            if sys.version_info >= (3,):
                config = configparser.RawConfigParser(defaults)
            else:
                config = ConfigParser.RawConfigParser(defaults)
            config.read(sys.argv[1])
        pickle.dump(self.run(config), sys.stdout.buffer)

def get_agent_cache(self):
        '''
        Return agent cached value for this specific plugin.
        '''
        try:
            return self.agent_cache[0]
        except Exception:
            return {}

def set_agent_cache(self, cache):
        '''
        Set agent cache value previously passed to this plugin instance.
        To enable caching existing agent_cache list have to be passed
        to Plugin on initialization.
        Minimally it should be list().
        Agent will be able to see only changes in zero element of agent_cache, so
        do not manually override self.agent_cache, othervice cache will not be saved!

If self.agent_cache is not a list appropriate exception will be raised.
        '''
        try:
            self.agent_cache[0] = cache
        except IndexError:
            self.agent_cache.append(cache)

def absolute_to_per_second(self, key, val, prev_cache):
        try:
            if val >= prev_cache[key]:
                value = \
                    (val - prev_cache[key]) / \
                    (time.time() - prev_cache['ts'])
            else:  # previous cached value should not be higher than current value (service was restarted?)
                value = val / \
                    (time.time() - prev_cache['ts'])
        except Exception:  # No cache yet, can't calculate
            value = 0
        return value

[-] wp-toolkit.py [open]
[+] ..
[-] plugins.py [open]
[-] yum-updates.py [open]
[-] proftpd.py [open]
[-] sleeper.py [open]
[-] network.py [open]
[+] __pycache__
[-] bird.py [open]
[-] diskusage.py [open]
[-] exim.py [open]
[-] cpanel.py [open]
[-] loggedin.py [open]
[-] memory.py [open]
[-] megacli.py [open]
[-] phpfpm.py [open]
[-] rabbitmq.py [open]
[-] elasticsearch.py [open]
[-] mysql.py [open]
[-] iostat.py [open]
[-] plesk-cgroups.py [open]
[-] fail2ban.py [open]
[-] loadavg.py [open]
[-] dirsize.py [open]
[-] openvpn.py [open]
[-] apt-updates.py [open]
[-] postfix.py [open]
[-] diskstatus.py [open]
[-] tcpports.py [open]
[-] haproxy.py [open]
[-] ping.py [open]
[-] unbound.py [open]
[-] dovecot.py [open]
[-] memcached.py [open]
[-] bitninja.py [open]
[-] powerdns.py [open]
[-] mailq.py [open]
[-] gpu.py [open]
[-] system.py [open]
[-] cloudlinux.py [open]
[-] cpu_freq.py [open]
[-] janus.py [open]
[-] nginx.py [open]
[-] bind.py [open]
[-] cpu.py [open]
[-] litespeed.py [open]
[-] swap.py [open]
[-] temp.py [open]
[-] kamailio.py [open]
[-] httpd.py [open]
[-] diskstatus-nvme.py [open]
[-] process.py [open]
[-] mongodb.py [open]
[-] __init__.py [open]
[-] minecraft.py [open]
[-] docker.py [open]
[-] vms.py [open]
[-] asterisk.py [open]
[-] redis_stat.py [open]
[-] mdstat.py [open]
[-] cloudlinux-dbgov.py [open]
[-] diskinodes.py [open]