in zktraffic/cli/printer.py [0:0]
def __init__(self, count, group_by, loopback, aggregation_depth, sort_by, output=sys.stdout, include_pings=True):
super(LatencyPrinter, self).__init__(False, loopback, output)
self._count, self._group_by, self._aggregation_depth = count, group_by, aggregation_depth
self._sort_by = sort_by
self._seen = 0
# FIXME: accounting pings is broken because their uniqueness is based on timestamps,
# so we disable them for tests.
self._include_pings = include_pings
self._latencies_by_group = defaultdict(list)
self._requests_by_client = defaultdict(Requests)
self._replies = deque()
self._report_done = False