Public Member Functions | |
| def | __init__ |
| def | get_db |
| def | handle_close_collection |
| def | handle_drop |
| def | handle_metadata |
| def | handle_pull |
| def | handle_query |
| def | handle_remove |
| def | handle_setup_collection |
| def | list_collections |
Public Attributes | |
| close_collection_srv | |
| connection | |
| drop_db | |
| handlers | |
| host | |
| initiate_query_srv | |
| list_collections_srv | |
| lock | |
| metadata_srv | |
| next_query_id | |
| port | |
| pull_message_srv | |
| query_handlers | |
| remove_msg_srv | |
| setup_collection | |
The mongo database interface. This serves as the backend to the warehouse.
Definition at line 353 of file backend.py.
| def backend::Backend::__init__ | ( | self, | ||
| host, | ||||
| port | ||||
| ) |
Constructor for the DB Interface. This creates a connection to the MonogDB and establishes a set of services
Definition at line 357 of file backend.py.
| def backend::Backend::get_db | ( | self, | ||
| name | ||||
| ) |
Create db if necessary.
Definition at line 504 of file backend.py.
| def backend::Backend::handle_close_collection | ( | self, | ||
| req | ||||
| ) |
Definition at line 520 of file backend.py.
| def backend::Backend::handle_drop | ( | self, | ||
| req | ||||
| ) |
Drop a database
Definition at line 470 of file backend.py.
| def backend::Backend::handle_metadata | ( | self, | ||
| req | ||||
| ) |
Definition at line 450 of file backend.py.
| def backend::Backend::handle_pull | ( | self, | ||
| req | ||||
| ) |
Cause next message on a query to be published
Definition at line 480 of file backend.py.
| def backend::Backend::handle_query | ( | self, | ||
| req | ||||
| ) |
Pass off the query to the appropriate collection
Definition at line 491 of file backend.py.
| def backend::Backend::handle_remove | ( | self, | ||
| req | ||||
| ) |
Definition at line 428 of file backend.py.
| def backend::Backend::handle_setup_collection | ( | self, | ||
| req | ||||
| ) |
Service callback that handles setting up new collection @param req: The whs.SetupCollection service request
Definition at line 548 of file backend.py.
| def backend::Backend::list_collections | ( | self, | ||
| req | ||||
| ) |
Service callback that handles db and collection existence checks @param req: The whs.ListCollections service request
Definition at line 531 of file backend.py.
Definition at line 389 of file backend.py.
Definition at line 374 of file backend.py.
Definition at line 414 of file backend.py.
Definition at line 363 of file backend.py.
Definition at line 365 of file backend.py.
Definition at line 404 of file backend.py.
Definition at line 394 of file backend.py.
Definition at line 385 of file backend.py.
Definition at line 419 of file backend.py.
Definition at line 386 of file backend.py.
Definition at line 366 of file backend.py.
Definition at line 409 of file backend.py.
Definition at line 387 of file backend.py.
Definition at line 424 of file backend.py.
Definition at line 399 of file backend.py.
