
Public Member Functions | |
| def | __init__ |
| def | dequeue |
| def | enqueue |
| def | init |
| def | is_quit |
| def | qsize |
| def | run |
| def | shutdown |
Public Attributes | |
| collection | |
| collname | |
| drop_counter | |
| id | |
| in_counter | |
| mongoconn | |
| mongodb | |
| mongodb_host | |
| mongodb_name | |
| mongodb_port | |
| name | |
| nodename_prefix | |
| out_counter | |
| process | |
| queue | |
| quit | |
| subscriber | |
| topic | |
| worker_drop_counter | |
| worker_in_counter | |
| worker_out_counter | |
Definition at line 125 of file mongodb_log.py.
| 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 126 of file mongodb_log.py.
| 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.
Definition at line 153 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 153 of file mongodb_log.py.
Definition at line 153 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 153 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.
Definition at line 126 of file mongodb_log.py.