(self, config=None)
Create a new instance of the LibratoHandler class
Create a new instance of the LibratoHandler class
Create a new instance of the LibratoHandler class
def __init__(self, config=None):
        """
        Create a new instance of the LibratoHandler class
        """
        # Initialize Handler
        Handler.__init__(self, config)
        logging.debug("Initialized Librato handler.")

        if librato is None:
            logging.error("Failed to load librato module")
            return

        # Initialize Options
        api = librato.connect(self.config['user'],
                              self.config['apikey'])
        self.queue = api.new_queue()
        self.queue_max_size = int(self.config['queue_max_size'])
        self.queue_max_interval = int(self.config['queue_max_interval'])
        self.queue_max_timestamp = int(time.time() + self.queue_max_interval)
        self.current_n_measurements = 0

        # If a user leaves off the ending comma, cast to a array for them
        include_filters = self.config['include_filters']
        if isinstance(include_filters, basestring):
            include_filters = [include_filters]

        self.include_reg = re.compile(r'(?:%s)' % '|'.join(include_filters))
def __init__ ( self , config = None ) : # Initialize Handler Handler . __init__ ( self , config ) logging . debug ( "Initialized Librato handler." ) if librato is None : logging . error ( "Failed to load librato module" ) return # Initialize Options api = librato . connect ( self . config [ 'user' ] , self . config [ 'apikey' ] ) self . queue = api . new_queue ( ) self . queue_max_size = int ( self . config [ 'queue_max_size' ] ) self . queue_max_interval = int ( self . config [ 'queue_max_interval' ] ) self . queue_max_timestamp = int ( time . time ( ) + self . queue_max_interval ) self . current_n_measurements = 0 # If a user leaves off the ending comma, cast to a array for them include_filters = self . config [ 'include_filters' ] if isinstance ( include_filters , basestring ) : include_filters = [ include_filters ] self . include_reg = re . compile ( r'(?:%s)' % '|' . join ( include_filters ) )