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 128 of file mongodb_log.py.
Constructor & Destructor Documentation
◆ __init__()
| 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 129 of file mongodb_log.py.
Member Function Documentation
◆ dequeue()
| def mongodb_log.WorkerProcess.dequeue | ( | self | ) |
Definition at line 236 of file mongodb_log.py.
◆ enqueue()
| def mongodb_log.WorkerProcess.enqueue | ( | self, | |
| data, | |||
| topic, | |||
current_time = None |
|||
| ) |
Definition at line 221 of file mongodb_log.py.
◆ init()
| def mongodb_log.WorkerProcess.init | ( | self | ) |
Definition at line 156 of file mongodb_log.py.
◆ is_quit()
| def mongodb_log.WorkerProcess.is_quit | ( | self | ) |
Definition at line 202 of file mongodb_log.py.
◆ qsize()
| def mongodb_log.WorkerProcess.qsize | ( | self | ) |
Definition at line 218 of file mongodb_log.py.
◆ run()
| def mongodb_log.WorkerProcess.run | ( | self | ) |
Definition at line 191 of file mongodb_log.py.
◆ shutdown()
| def mongodb_log.WorkerProcess.shutdown | ( | self | ) |
Definition at line 205 of file mongodb_log.py.
Member Data Documentation
◆ collection
| mongodb_log.WorkerProcess.collection |
Definition at line 165 of file mongodb_log.py.
◆ collname
| mongodb_log.WorkerProcess.collname |
Definition at line 133 of file mongodb_log.py.
◆ drop_counter
| mongodb_log.WorkerProcess.drop_counter |
Definition at line 137 of file mongodb_log.py.
◆ id
| mongodb_log.WorkerProcess.id |
Definition at line 131 of file mongodb_log.py.
◆ in_counter
| mongodb_log.WorkerProcess.in_counter |
Definition at line 136 of file mongodb_log.py.
◆ mongoconn
| mongodb_log.WorkerProcess.mongoconn |
Definition at line 161 of file mongodb_log.py.
◆ mongodb
| mongodb_log.WorkerProcess.mongodb |
Definition at line 162 of file mongodb_log.py.
◆ mongodb_host
| mongodb_log.WorkerProcess.mongodb_host |
Definition at line 141 of file mongodb_log.py.
◆ mongodb_name
| mongodb_log.WorkerProcess.mongodb_name |
Definition at line 143 of file mongodb_log.py.
◆ mongodb_port
| mongodb_log.WorkerProcess.mongodb_port |
Definition at line 142 of file mongodb_log.py.
◆ name
| mongodb_log.WorkerProcess.name |
Definition at line 130 of file mongodb_log.py.
◆ nodename_prefix
| mongodb_log.WorkerProcess.nodename_prefix |
Definition at line 144 of file mongodb_log.py.
◆ out_counter
| mongodb_log.WorkerProcess.out_counter |
Definition at line 135 of file mongodb_log.py.
◆ process
| mongodb_log.WorkerProcess.process |
Definition at line 148 of file mongodb_log.py.
◆ queue
| mongodb_log.WorkerProcess.queue |
Definition at line 134 of file mongodb_log.py.
◆ quit
| mongodb_log.WorkerProcess.quit |
Definition at line 145 of file mongodb_log.py.
◆ subscriber
| mongodb_log.WorkerProcess.subscriber |
Definition at line 178 of file mongodb_log.py.
◆ topic
| mongodb_log.WorkerProcess.topic |
Definition at line 132 of file mongodb_log.py.
◆ worker_drop_counter
| mongodb_log.WorkerProcess.worker_drop_counter |
Definition at line 140 of file mongodb_log.py.
◆ worker_in_counter
| mongodb_log.WorkerProcess.worker_in_counter |
Definition at line 139 of file mongodb_log.py.
◆ worker_out_counter
| mongodb_log.WorkerProcess.worker_out_counter |
Definition at line 138 of file mongodb_log.py.
The documentation for this class was generated from the following file: