def load_plugins(self):
        """Refresh the list of available collectors and auditors

        Returns:
            `None`
        """
        for entry_point in CINQ_PLUGINS['cloud_inquisitor.plugins.collectors']['plugins']:
            cls = entry_point.load()
            if cls.enabled():
                self.log.debug('Collector loaded: {} in module {}'.format(cls.__name__, cls.__module__))
                self.collectors.setdefault(cls.type, []).append(Worker(
                    cls.name,
                    cls.interval,
                    {
                        'name': entry_point.name,
                        'module_name': entry_point.module_name,
                        'attrs': entry_point.attrs
                    }
                ))
            else:
                self.log.debug('Collector disabled: {} in module {}'.format(cls.__name__, cls.__module__))

        for entry_point in CINQ_PLUGINS['cloud_inquisitor.plugins.auditors']['plugins']:
            cls = entry_point.load()
            if cls.enabled():
                self.log.debug('Auditor loaded: {} in module {}'.format(cls.__name__, cls.__module__))
                self.auditors.append(Worker(
                    cls.name,
                    cls.interval,
                    {
                        'name': entry_point.name,
                        'module_name': entry_point.module_name,
                        'attrs': entry_point.attrs
                    }
                ))
            else:
                self.log.debug('Auditor disabled: {} in module {}'.format(cls.__name__, cls.__module__))

        collector_count = sum(len(x) for x in self.collectors.values())
        auditor_count = len(self.auditors)

        if collector_count + auditor_count == 0:
            raise Exception('No auditors or collectors loaded, aborting scheduler')

        self.log.info('Scheduler loaded {} collectors and {} auditors'.format(collector_count, auditor_count))
def load_plugins ( self ) : for entry_point in CINQ_PLUGINS [ 'cloud_inquisitor.plugins.collectors' ] [ 'plugins' ] : cls = entry_point . load ( ) if cls . enabled ( ) : self . log . debug ( 'Collector loaded: {} in module {}' . format ( cls . __name__ , cls . __module__ ) ) self . collectors . setdefault ( cls . type , [ ] ) . append ( Worker ( cls . name , cls . interval , { 'name' : entry_point . name , 'module_name' : entry_point . module_name , 'attrs' : entry_point . attrs } ) ) else : self . log . debug ( 'Collector disabled: {} in module {}' . format ( cls . __name__ , cls . __module__ ) ) for entry_point in CINQ_PLUGINS [ 'cloud_inquisitor.plugins.auditors' ] [ 'plugins' ] : cls = entry_point . load ( ) if cls . enabled ( ) : self . log . debug ( 'Auditor loaded: {} in module {}' . format ( cls . __name__ , cls . __module__ ) ) self . auditors . append ( Worker ( cls . name , cls . interval , { 'name' : entry_point . name , 'module_name' : entry_point . module_name , 'attrs' : entry_point . attrs } ) ) else : self . log . debug ( 'Auditor disabled: {} in module {}' . format ( cls . __name__ , cls . __module__ ) ) collector_count = sum ( len ( x ) for x in self . collectors . values ( ) ) auditor_count = len ( self . auditors ) if collector_count + auditor_count == 0 : raise Exception ( 'No auditors or collectors loaded, aborting scheduler' ) self . log . info ( 'Scheduler loaded {} collectors and {} auditors' . format ( collector_count , auditor_count ) )
Refresh the list of available collectors and auditors

        Returns:
            `None`