| | |
- exceptions.Exception(exceptions.BaseException)
-
- InvalidExpandableError
- NoHitException
- SpoolingRequestError
- BowserSessionStore
- Browser
-
- Bowser(Browser, pydi.reqspool.RequestProcessor, pydi.datadir.ClsRecordLoadedMonitor, pydi.datadir.ConcreteLinkLoadedMonitor)
- BrowserCacheInterface
- TimedLock
- pydi.reqspool.RequestExecutor
-
- DataSetGeneratorExecutor
class Bowser(Browser, pydi.reqspool.RequestProcessor, pydi.datadir.ClsRecordLoadedMonitor, pydi.datadir.ConcreteLinkLoadedMonitor) |
| |
Bowser browsing engine. This implementation of the Browser interface relies
on a relational-DB like interaction (i.e., straight-up referencing of the DataDirectory,
which stores data as if they were tabled records in a DB).
|
| |
- Method resolution order:
- Bowser
- Browser
- pydi.reqspool.RequestProcessor
- pydi.callback.UpdateObserver
- pydi.datadir.ClsRecordLoadedMonitor
- pydi.datadir.ConcreteLinkLoadedMonitor
Methods defined here:
- __init__(self, cat, seeds=None, states=None, loaded=None, pending=None, dd=None, mem_cfg=None, p_cache=None)
- add_dataset_load_listener(self, ds_listener)
- Browser will pass a complete dataset when it appears.
- add_instance_listener(self, inst_listener)
- Browser will pass an instance listener the instance when it appears.
- add_link_listener(self, lnk_listener)
- Browser will pass a link listener the link instance when it appears.
- add_query_listener(self, q_listener)
- Browser will pass a query when it appears.
- contains_record(self, src_str, ref_str)
- end_session = lockfnc(*args, **kwargs)
- entity_status(self)
- expand(self, hsrc_str, hid_str)
- Expand the entity with specified source and ID; ignores source state.
- expand_all(self)
- Expands all queries -- does not expand inactive sources.
- get_all_instances(self)
- get_all_instances_of_type_str(self, cls_type_str)
- get_all_links(self)
- get_data_directory(self)
- Returns the data directory, which stores all the retrieved data in a series of databases.
- get_instance_source_id(self, src_name, id_name)
- get_record(self, src_str, id_str)
- get_seeds(self)
- Returns the seeds (user-specified queries).
- is_busy = lockfnc(*args, **kwargs)
- list_expandables(self)
- List links that have yet to be expanded.
- load_datasets(self, fname)
- loaded_instance(self, ref, scls, db)
- Callback to when an entity instance is loaded (scls is a SourcedClassInstance
- loaded_link(self, ref, clink, db)
- Callback to when a link is loaded.
- pause = lockfnc(*args, **kwargs)
- queries_suppressed(self)
- request_status = lockfnc(*args, **kwargs)
- resume = lockfnc(*args, **kwargs)
- save_datasets(self, fname)
- save_session(self, name)
- Saves a session.
- seed(self, source_str, cls_str, prop_str, value)
- Seed a query to the specified source, class and property.
- set_persistent_cache(self, bci)
- Sets a persistent cache to use.
- source_enabled(self, src_name_str, bool)
- Note: this doesn't check against the source catalog (srccat initialized sources as they are first encountered...)
- source_request_status = lockfnc(*args, **kwargs)
- suppress_queries(self, do_sup)
- update(self, msg)
- msg is an object of type reqspool.RequestOrderResponse
Static methods defined here:
- load_session(name)
- Loads a session.
Data descriptors defined here:
- seeds
- Returns the seeds (user-specified queries).
Data and other attributes defined here:
- ent_state_lock = <thread.lock object at 0x7ff12140>
- spoolerStatusLock = <thread.lock object at 0x7ff12150>
Methods inherited from Browser:
- add_cache_hit_listener(self, c_listener)
|
class Browser |
| |
Abstract class for a browsing engine. Concrete browsing engines should
extend this.
|
| |
Methods defined here:
- add_cache_hit_listener(self, c_listener)
- add_instance_listener(self, inst_listener)
- add_link_listener(self, lnk_listener)
- add_query_listener(self, q_listener)
- expand(self, src_name, id_name)
- is_busy(self)
- loaded_instance(self, ref, scls, db)
- loaded_link(self, ref, clink, db)
- seed(self, source, cls, prop, value)
|
class BrowserCacheInterface |
| |
Abstract interface for checking the contents of a cache.
Basic functionality is checking if a record is in the cache,
and retrieving the record in the cache.
|
| |
Methods defined here:
- add_dataset(self, ds)
- Adds a dataset to the cache (leave it to invidual implementing caches
to determine how to handle duplicates, overwriting, etc.)
- get_record(self, source_str, ref_str)
- Returns the record defined by the source and reference (key).
Throws a NoHitException otherwise.
- has_record(self, source_str, ref_str)
- Returns True if the record is in the cache, False otherwise.
|
class TimedLock |
| |
Acts like threading.Lock, but there is a specifiable delay after the lock is released.
|
| |
Methods defined here:
- __init__(self, sleep_sec, label=None)
- acquire(self)
- get_label(self)
- release(self)
Data descriptors defined here:
- label
| |