kopia lustrzana https://github.com/wagtail/wagtail
refactor(search/elastic): Allow rebuilder classes to be swapped
rodzic
ee10c18552
commit
3bcb722a5f
|
@ -577,6 +577,8 @@ class ElasticSearch(BaseSearch):
|
||||||
query_class = ElasticSearchQuery
|
query_class = ElasticSearchQuery
|
||||||
results_class = ElasticSearchResults
|
results_class = ElasticSearchResults
|
||||||
mapping_class = ElasticSearchMapping
|
mapping_class = ElasticSearchMapping
|
||||||
|
basic_rebuilder_class = ElasticSearchIndexRebuilder
|
||||||
|
atomic_rebuilder_class = ElasticSearchAtomicIndexRebuilder
|
||||||
|
|
||||||
def __init__(self, params):
|
def __init__(self, params):
|
||||||
super(ElasticSearch, self).__init__(params)
|
super(ElasticSearch, self).__init__(params)
|
||||||
|
@ -587,9 +589,9 @@ class ElasticSearch(BaseSearch):
|
||||||
self.es_timeout = params.pop('TIMEOUT', 10)
|
self.es_timeout = params.pop('TIMEOUT', 10)
|
||||||
|
|
||||||
if params.pop('ATOMIC_REBUILD', False):
|
if params.pop('ATOMIC_REBUILD', False):
|
||||||
self.rebuilder_class = ElasticSearchAtomicIndexRebuilder
|
self.rebuilder_class = self.atomic_rebuilder_class
|
||||||
else:
|
else:
|
||||||
self.rebuilder_class = ElasticSearchIndexRebuilder
|
self.rebuilder_class = self.basic_rebuilder_class
|
||||||
|
|
||||||
# If HOSTS is not set, convert URLS setting to HOSTS
|
# If HOSTS is not set, convert URLS setting to HOSTS
|
||||||
es_urls = params.pop('URLS', ['http://localhost:9200'])
|
es_urls = params.pop('URLS', ['http://localhost:9200'])
|
||||||
|
|
Ładowanie…
Reference in New Issue