pyams_content_es package¶
+Subpackages¶
+ +Submodules¶
+pyams_content_es.document module¶
+-
+
-
+class
pyams_content_es.document.
ElasticMixin
¶
+ Bases:
+pyramid_es.mixin.ElasticMixin
ElasticSearch base mixin class
+-
+
-
+
elastic_document
()¶
+
-
+
-
+
elastic_mapping
()¶
+
-
+
-
+
id
¶
+
-
+
-
+
internal_id
¶
+
-
+
-
+
pyams_content_es.include module¶
+-
+
-
+
pyams_content_es.include.
handle_new_application
(event)¶
+ Start indexer process when application created
+
-
+
-
+
pyams_content_es.include.
include_package
(config)¶
+ Pyramid include
+
pyams_content_es.index module¶
+-
+
-
+
pyams_content_es.index.
handle_added_document
(event)¶
+ Handle added document
+
-
+
-
+
pyams_content_es.index.
handle_modified_document
(event)¶
+ Handle modified document
+
-
+
-
+
pyams_content_es.index.
handle_removed_document
(event)¶
+ Handle removed document
+
-
+
-
+
pyams_content_es.index.
index_document
(status, document)¶
+
-
+
-
+
pyams_content_es.index.
unindex_document
(status, document)¶
+
pyams_content_es.process module¶
+-
+
-
+class
pyams_content_es.process.
BaseIndexerProcess
(settings, group=None, target=None, name=None, *args, **kwargs)¶
+ Bases:
+multiprocessing.context.Process
Base indexer process
+-
+
-
+
run
()¶
+
-
+
-
+
update_index
(client, document)¶
+ Update index
+
-
+
-
+
-
+class
pyams_content_es.process.
ContentIndexerHandler
¶
+ Bases:
+object
Content indexer handler
+-
+
-
+
index
(settings)¶
+
-
+
-
+
test
(settings)¶
+
-
+
-
+
unindex
(settings)¶
+
-
+
-
+
-
+class
pyams_content_es.process.
ContentIndexerMessageHandler
(process, stream, stop, handler=None, json_load=-1)¶
+ Bases:
+pyams_zmq.handler.ZMQMessageHandler
Content indexer message handler
+-
+
-
+
handler
¶
+ alias of
+ContentIndexerHandler
-
+
-
+
-
+class
pyams_content_es.process.
ContentIndexerProcess
(zmq_address, handler, registry)¶
+ Bases:
+pyams_zmq.process.ZMQProcess
Content indexer ZMQ process
+
-
+
-
+class
pyams_content_es.process.
IndexerProcess
(settings, group=None, target=None, name=None, *args, **kwargs)¶
+ Bases:
+pyams_content_es.process.BaseIndexerProcess
Content indexer process
+-
+
-
+
update_index
(client, document)¶
+
-
+
-
+
-
+class
pyams_content_es.process.
IndexerThread
(process)¶
+ Bases:
+threading.Thread
Content indexer thread
+-
+
-
+
run
()¶
+
-
+
-
+
-
+class
pyams_content_es.process.
UnindexerProcess
(settings, group=None, target=None, name=None, *args, **kwargs)¶
+ Bases:
+pyams_content_es.process.BaseIndexerProcess
Content un-indexer process
+-
+
-
+
update_index
(client, document)¶
+
-
+
pyams_content_es.site module¶
+-
+
-
+class
pyams_content_es.site.
ContentIndexerGenerationsChecker
¶
+ Bases:
+object
Content indexer utility generations checker
+-
+
-
+
evolve
(site, current=None)¶
+ Check for required utilities
+
-
+
-
+
generation
= 1¶
+
-
+
-
+
-
+
pyams_content_es.site.
handle_new_local_site
(event)¶
+ Create a new indexer utility when a site is created
+
-
+
-
+
pyams_content_es.site.
site_index
(request)¶
+ Index all site contents in ElasticSearch
+
pyams_content_es.utility module¶
+-
+
-
+class
pyams_content_es.utility.
ContentIndexerUtility
¶
+ Bases:
+persistent.Persistent
,zope.container.contained.Contained
Content indexer utility
+-
+
-
+
index_document
(document)¶
+ Send index request for given document
+
-
+
-
+
test_process
()¶
+ Send test request to indexer process
+
-
+
-
+
unindex_document
(document)¶
+ Send unindex request for given document
+
-
+
-
+
zodb_name
¶
+ Computed attributes based on schema fields
+Field properties provide default values, data validation and error messages +based on data found in field meta-data.
+Note that FieldProperties cannot be used with slots. They can only +be used for attributes stored in instance dictionaries.
+
-
+