# Path: collectors/etc/mapr_metrics_conf.py
# def enabled():
# def get_config():
# 
# Path: collectors/lib/utils.py
# PY3 = sys.version_info[0] > 2
# USER = "nobody"
# def drop_privileges(user=USER):
# def is_sockfile(path):
# def err(msg):
#     def is_numeric(value):
#     def is_numeric(value):


import datetime
import sys
import platform
import sys
import time
import re
  import requests
from datetime import timedelta
from string import Template
from collectors.etc import mapr_metrics_conf
from collectors.lib import utils
  from collectors.etc import mapr_metrics_conf
              self.send_counter(rpccount_metric, self.last_values[rpccount_metric], d['RPCCOUNT'], timestamp, tags=tags)
            self.last_values[rpccount_metric] = d['RPCCOUNT']
          except KeyError as e:
            utils.err('%s is not in metrics data.' % e)

          try:
            rpcinbytes_metric = self.metric_template.substitute(grouping='rpc', metric='inbytes')
            if rpcinbytes_metric in self.last_values:
              self.send_counter(rpcinbytes_metric, self.last_values[rpcinbytes_metric], d['RPCINBYTES'], timestamp, tags=tags)
            self.last_values[rpcinbytes_metric] = d['RPCINBYTES']
          except KeyError as e:
            utils.err('%s is not in metrics data.' % e)

          try:
            rpcoutbytes_metric = self.metric_template.substitute(grouping='rpc', metric='outbytes')
            if rpcoutbytes_metric in self.last_values:
              self.send_counter(rpcoutbytes_metric, self.last_values[rpcoutbytes_metric], d['RPCOUTBYTES'], timestamp, tags=tags)
            self.last_values[rpcoutbytes_metric] = d['RPCOUTBYTES']
          except KeyError as e:
            utils.err('%s is not in metrics data.' % e)
      time.sleep(seconds_delay)


  def group_metrics(self, group, last_values, all_metrics, tags={}):
    node = all_metrics['NODE']
    timestamp = int(all_metrics['TIMESTAMP']) / 1000

    for (obj, obj_metrics) in all_metrics[group].items():
      for (metric_name, value) in obj_metrics.items():
        t = tags.copy()

# Path: collectors/etc/mapr_metrics_conf.py
# def enabled():
# def get_config():
# 
# Path: collectors/lib/utils.py
# PY3 = sys.version_info[0] > 2
# USER = "nobody"
# def drop_privileges(user=USER):
# def is_sockfile(path):
# def err(msg):
#     def is_numeric(value):
#     def is_numeric(value):


# Path: collectors/0/mapr_metrics.py
import datetime
import sys
import platform
import sys
import time
import re
  import requests
from datetime import timedelta
from string import Template
from collectors.etc import mapr_metrics_conf
from collectors.lib import utils
  from collectors.etc import mapr_metrics_conf

              self.send_counter(rpccount_metric, self.last_values[rpccount_metric], d['RPCCOUNT'], timestamp, tags=tags)
            self.last_values[rpccount_metric] = d['RPCCOUNT']
          except KeyError as e:
            utils.err('%s is not in metrics data.' % e)

          try:
            rpcinbytes_metric = self.metric_template.substitute(grouping='rpc', metric='inbytes')
            if rpcinbytes_metric in self.last_values:
              self.send_counter(rpcinbytes_metric, self.last_values[rpcinbytes_metric], d['RPCINBYTES'], timestamp, tags=tags)
            self.last_values[rpcinbytes_metric] = d['RPCINBYTES']
          except KeyError as e:
            utils.err('%s is not in metrics data.' % e)

          try:
            rpcoutbytes_metric = self.metric_template.substitute(grouping='rpc', metric='outbytes')
            if rpcoutbytes_metric in self.last_values:
              self.send_counter(rpcoutbytes_metric, self.last_values[rpcoutbytes_metric], d['RPCOUTBYTES'], timestamp, tags=tags)
            self.last_values[rpcoutbytes_metric] = d['RPCOUTBYTES']
          except KeyError as e:
            utils.err('%s is not in metrics data.' % e)
      time.sleep(seconds_delay)


  def group_metrics(self, group, last_values, all_metrics, tags={}):
    node = all_metrics['NODE']
    timestamp = int(all_metrics['TIMESTAMP']) / 1000

    for (obj, obj_metrics) in all_metrics[group].items():
      for (metric_name, value) in obj_metrics.items():
        t = tags.copy()

        if group == 'DISKS':