grep_queue_timestamps = []
auditor_queue_sizes = []
auditor_queue_timestamps = []
crawl_queue_sizes = []
crawl_queue_timestamps = []
for line in scan:
match = GREP_DISK_DICT.search(line)
if match:
grep_queue_sizes.append(int(match.group(1)))
grep_queue_timestamps.append(get_line_epoch(line))
match = AUDITOR_DISK_DICT.search(line)
if match:
auditor_queue_sizes.append(int(match.group(1)))
auditor_queue_timestamps.append(get_line_epoch(line))
match = CRAWLINFRA_DISK_DICT.search(line)
if match:
crawl_queue_sizes.append(int(match.group(1)))
crawl_queue_timestamps.append(get_line_epoch(line))
// Get the last timestamp to use as max in the graphs
last_timestamp = get_line_epoch(line)
print("Consumer queue sizes")
print("")
fig = plotille.Figure()
fig.width = 90
fig.height = 20
fig.y_label = "Items in Audit queue"
fig.x_label = "Time"
fig.color_mode = "byte"
fig.set_x_limits(min_=auditor_queue_timestamps[0], max_=last_timestamp)
fig.set_y_limits(min_=0, max_=None)
fig.plot(auditor_queue_timestamps,