aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDavid Hurst2017-04-19 09:57:00 -0600
committerDavid Hurst2017-04-19 10:01:47 -0600
commit05e9aef96205e1eac40ac91a722c533f03e8ebb3 (patch)
tree2beff9ac5866b9c6c1e172228d1070c514b66757
parent665d75c2a79d11064dd044f6ab31ae0a73c23ae8 (diff)
downloadeventmq-05e9aef96205e1eac40ac91a722c533f03e8ebb3.tar.gz
eventmq-05e9aef96205e1eac40ac91a722c533f03e8ebb3.zip
Add docs to metrics
-rw-r--r--eventmq/jobmanager.py11
1 files changed, 9 insertions, 2 deletions
diff --git a/eventmq/jobmanager.py b/eventmq/jobmanager.py
index ec15b3c..4840fac 100644
--- a/eventmq/jobmanager.py
+++ b/eventmq/jobmanager.py
@@ -106,11 +106,18 @@ class JobManager(HeartbeatMixin, EMQPService):
106 106
107 self.poller = Poller() 107 self.poller = Poller()
108 108
109 # Stats and monitoring information 109 #: Stats and monitoring information
110
111 #: Jobs in flight tracks all jobs currently executing.
112 #: Key: msgid, Value: The message with all the details of the job
110 self.jobs_in_flight = {} 113 self.jobs_in_flight = {}
114
115 #: Running total number of REQUEST messages received on the broker
111 self.total_requests = 0 116 self.total_requests = 0
117 #: Running total number of READY messages sent to the broker
112 self.total_ready_sent = 0 118 self.total_ready_sent = 0
113 # Keep track of what pids are servicing our requests 119 #: Keep track of what pids are servicing our requests
120 #: Key: pid, Value: # of jobs completed on the process with that pid
114 self.pid_distribution = {} 121 self.pid_distribution = {}
115 122
116 #: Setup worker queues 123 #: Setup worker queues