diff options
| author | David Hurst | 2017-04-19 09:57:00 -0600 |
|---|---|---|
| committer | David Hurst | 2017-04-19 10:01:47 -0600 |
| commit | 05e9aef96205e1eac40ac91a722c533f03e8ebb3 (patch) | |
| tree | 2beff9ac5866b9c6c1e172228d1070c514b66757 | |
| parent | 665d75c2a79d11064dd044f6ab31ae0a73c23ae8 (diff) | |
| download | eventmq-05e9aef96205e1eac40ac91a722c533f03e8ebb3.tar.gz eventmq-05e9aef96205e1eac40ac91a722c533f03e8ebb3.zip | |
Add docs to metrics
| -rw-r--r-- | eventmq/jobmanager.py | 11 |
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 |