Public Member Functions | |
| def | __init__ |
| def | cleanup |
| def | handle_metadata |
| def | handle_push |
| def | handle_remove |
| def | initiate_query |
| def | pull_message |
Public Attributes | |
| collection | |
| connection | |
| cursors | |
| db | |
| fs | |
| indexed_fields | |
| msg_class | |
| pub | |
| publish_messages | |
| query_metadata_pubs | |
| query_pubs | |
| sub | |
A class that handles insertion of data in a collection.
Definition at line 135 of file backend.py.
| def backend::CollectionHandler::__init__ | ( | self, | ||
| req, | ||||
| msg_class, | ||||
| conn, | ||||
| topic | ||||
| ) |
Constructor. Listens to a topic named /warehouse/<db_name>/<collection_name>/insert. Inserts data of the type <msg_type> when it comes in over the wire. @param req: The SetupCollection service request @param msg_type: The message data type @param conn: The connection to the db @param topic: The topic to push data on @todo Should check the indexed fields for correctness here rather than dying in the callback
Definition at line 140 of file backend.py.
| def backend::CollectionHandler::cleanup | ( | self | ) |
Definition at line 177 of file backend.py.
| def backend::CollectionHandler::handle_metadata | ( | self, | ||
| req | ||||
| ) |
Definition at line 291 of file backend.py.
| def backend::CollectionHandler::handle_push | ( | self, | ||
| raw_msg | ||||
| ) |
Handles the insertion of data into a collection.
Definition at line 181 of file backend.py.
| def backend::CollectionHandler::handle_remove | ( | self, | ||
| cond | ||||
| ) |
Definition at line 265 of file backend.py.
| def backend::CollectionHandler::initiate_query | ( | self, | ||
| req, | ||||
| id | ||||
| ) |
Definition at line 221 of file backend.py.
| def backend::CollectionHandler::pull_message | ( | self, | ||
| id | ||||
| ) |
Definition at line 247 of file backend.py.
Definition at line 157 of file backend.py.
Definition at line 155 of file backend.py.
Definition at line 159 of file backend.py.
Definition at line 156 of file backend.py.
Definition at line 158 of file backend.py.
Definition at line 168 of file backend.py.
Definition at line 162 of file backend.py.
Definition at line 174 of file backend.py.
Definition at line 163 of file backend.py.
Definition at line 161 of file backend.py.
Definition at line 160 of file backend.py.
Definition at line 171 of file backend.py.
