Public Member Functions | |
| def | __init__ (self, idnum, topic, collname, in_counter_value, out_counter_value, drop_counter_value, queue_maxsize, mongodb_host, mongodb_port, mongodb_name, nodename_prefix) |
| def | dequeue (self) |
| def | enqueue (self, data, topic, current_time=None) |
| def | init (self) |
| def | is_quit (self) |
| def | qsize (self) |
| def | run (self) |
| def | shutdown (self) |
Detailed Description
Definition at line 125 of file mongodb_log.py.
Constructor & Destructor Documentation
| def mongodb_log.WorkerProcess.__init__ | ( | self, | |
| idnum, | |||
| topic, | |||
| collname, | |||
| in_counter_value, | |||
| out_counter_value, | |||
| drop_counter_value, | |||
| queue_maxsize, | |||
| mongodb_host, | |||
| mongodb_port, | |||
| mongodb_name, | |||
| nodename_prefix | |||
| ) |
Definition at line 128 of file mongodb_log.py.
Member Function Documentation
| def mongodb_log.WorkerProcess.dequeue | ( | self | ) |
Definition at line 233 of file mongodb_log.py.
| def mongodb_log.WorkerProcess.enqueue | ( | self, | |
| data, | |||
| topic, | |||
current_time = None |
|||
| ) |
Definition at line 218 of file mongodb_log.py.
| def mongodb_log.WorkerProcess.init | ( | self | ) |
Definition at line 153 of file mongodb_log.py.
| def mongodb_log.WorkerProcess.is_quit | ( | self | ) |
Definition at line 199 of file mongodb_log.py.
| def mongodb_log.WorkerProcess.qsize | ( | self | ) |
Definition at line 215 of file mongodb_log.py.
| def mongodb_log.WorkerProcess.run | ( | self | ) |
Definition at line 188 of file mongodb_log.py.
| def mongodb_log.WorkerProcess.shutdown | ( | self | ) |
Definition at line 202 of file mongodb_log.py.
Member Data Documentation
| mongodb_log.WorkerProcess.collection |
Definition at line 162 of file mongodb_log.py.
| mongodb_log.WorkerProcess.collname |
Definition at line 132 of file mongodb_log.py.
| mongodb_log.WorkerProcess.drop_counter |
Definition at line 136 of file mongodb_log.py.
| mongodb_log.WorkerProcess.id |
Definition at line 130 of file mongodb_log.py.
| mongodb_log.WorkerProcess.in_counter |
Definition at line 135 of file mongodb_log.py.
| mongodb_log.WorkerProcess.mongoconn |
Definition at line 158 of file mongodb_log.py.
| mongodb_log.WorkerProcess.mongodb |
Definition at line 159 of file mongodb_log.py.
| mongodb_log.WorkerProcess.mongodb_host |
Definition at line 140 of file mongodb_log.py.
| mongodb_log.WorkerProcess.mongodb_name |
Definition at line 142 of file mongodb_log.py.
| mongodb_log.WorkerProcess.mongodb_port |
Definition at line 141 of file mongodb_log.py.
| mongodb_log.WorkerProcess.name |
Definition at line 129 of file mongodb_log.py.
| mongodb_log.WorkerProcess.nodename_prefix |
Definition at line 143 of file mongodb_log.py.
| mongodb_log.WorkerProcess.out_counter |
Definition at line 134 of file mongodb_log.py.
| mongodb_log.WorkerProcess.process |
Definition at line 147 of file mongodb_log.py.
| mongodb_log.WorkerProcess.queue |
Definition at line 133 of file mongodb_log.py.
| mongodb_log.WorkerProcess.quit |
Definition at line 144 of file mongodb_log.py.
| mongodb_log.WorkerProcess.subscriber |
Definition at line 175 of file mongodb_log.py.
| mongodb_log.WorkerProcess.topic |
Definition at line 131 of file mongodb_log.py.
| mongodb_log.WorkerProcess.worker_drop_counter |
Definition at line 139 of file mongodb_log.py.
| mongodb_log.WorkerProcess.worker_in_counter |
Definition at line 138 of file mongodb_log.py.
| mongodb_log.WorkerProcess.worker_out_counter |
Definition at line 137 of file mongodb_log.py.
The documentation for this class was generated from the following file: