Package org.craftercms.search.opensearch.impl

Class MultiOpenSearchServiceImpl

java.lang.Object

org.craftercms.search.opensearch.impl.OpenSearchServiceImpl

org.craftercms.search.opensearch.impl.MultiOpenSearchServiceImpl

All Implemented Interfaces:

AutoCloseable, OpenSearchService

public class MultiOpenSearchServiceImpl
extends OpenSearchServiceImpl

Extension of OpenSearchServiceImpl that handles multiple OpenSearch clusters

Since:

3.1.5

Author:

joseross

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opensearch.client.opensearch.OpenSearchClient[]	writeClients	OpenSearch clients used for write-related operations

Fields inherited from class org.craftercms.search.opensearch.impl.OpenSearchServiceImpl

DEFAULT_LOCAL_ID_NAME, DEFAULT_SCROLL_SIZE, DEFAULT_SCROLL_TIMEOUT, documentBuilder, documentParser, localIdFieldName, openSearchClient, scrollSize, scrollTimeout

Constructor Summary

Constructors

Constructor	Description
MultiOpenSearchServiceImpl(OpenSearchDocumentBuilder documentBuilder, DocumentParser documentParser, org.opensearch.client.opensearch.OpenSearchClient readClient, org.opensearch.client.opensearch.OpenSearchClient[] writeClients)

Method Summary

Modifier and Type	Method	Description
void	close()
void	delete(String indexName, String siteName, String docId)	Performs a delete for the given document
void	index(String indexName, String siteName, String docId, Map<String,Object> doc)

Methods inherited from class org.craftercms.search.opensearch.impl.OpenSearchServiceImpl

doDelete, doIndex, doRefresh, getId, index, indexBinary, indexBinary, refresh, searchField, searchId, setLocalIdFieldName, setScrollSize, setScrollTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.craftercms.search.opensearch.OpenSearchService

index, indexBinary, indexBinary

Field Details

writeClients

protected final org.opensearch.client.opensearch.OpenSearchClient[] writeClients

OpenSearch clients used for write-related operations

Constructor Details

MultiOpenSearchServiceImpl

public MultiOpenSearchServiceImpl(OpenSearchDocumentBuilder documentBuilder,
 DocumentParser documentParser,
 org.opensearch.client.opensearch.OpenSearchClient readClient,
 org.opensearch.client.opensearch.OpenSearchClient[] writeClients)

Method Details

delete

public void delete(String indexName,
 String siteName,
 String docId)
            throws OpenSearchException

Performs a delete for the given document

Specified by:

delete in interface OpenSearchService

Overrides:

delete in class OpenSearchServiceImpl

Parameters:

indexName - the name of the index

siteName - the id of the site

docId - the id of the document

Throws:

OpenSearchException - if there is any error during the operation

index

public void index(String indexName,
 String siteName,
 String docId,
 Map<String,Object> doc)
           throws OpenSearchException

Specified by:

index in interface OpenSearchService

Overrides:

index in class OpenSearchServiceImpl

Throws:

OpenSearchException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class OpenSearchServiceImpl

Throws:

Exception