- -
-

pyams_content_es package

- -
-

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.document.WfSharedContentIndexInfo(content)
-
- -
-
-

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.

-
- -
- -
-
-

Module contents

-
-
-pyams_content_es.includeme(config)
-

Pyramid include

-
- -
-
- - -