def _report_self(self):
        '''
        Reports the kafka monitor uuid to redis
        '''
        key = "stats:kafka-monitor:self:{m}:{u}".format(
            m=socket.gethostname(),
            u=self.my_uuid)
        self.redis_conn.set(key, time.time())
        self.redis_conn.expire(key, self.settings['HEARTBEAT_TIMEOUT'])
def _report_self ( self ) : key = "stats:kafka-monitor:self:{m}:{u}" . format ( m = socket . gethostname ( ) , u = self . my_uuid ) self . redis_conn . set ( key , time . time ( ) ) self . redis_conn . expire ( key , self . settings [ 'HEARTBEAT_TIMEOUT' ] )
Reports the kafka monitor uuid to redis