def register_accumulator()

in zktraffic/stats/loaders.py [0:0]

• 8 lines of code
• 4 McCabe index (conditional complexity)

  def register_accumulator(self, name, accumulator):
    # TODO : Disallow registration after thread start
    self._accumulators[name] = accumulator
    if hasattr(accumulator, 'update_request_stats'):
      self._request_handlers.add(accumulator.update_request_stats)
    if hasattr(accumulator, 'update_reply_stats'):
      self._reply_handlers.add(accumulator.update_reply_stats)
    if hasattr(accumulator, 'update_event_stats'):
      self._event_handlers.add(accumulator.update_event_stats)