Package org.nuxeo.runtime.opensearch1.client

Class OpenSearchRestClientFactory

java.lang.Object

org.nuxeo.runtime.opensearch1.client.OpenSearchRestClientFactory

All Implemented Interfaces:

OpenSearchClientFactory

public class OpenSearchRestClientFactory
extends Object
implements OpenSearchClientFactory

Since:

9.3

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	DEFAULT_CONNECT_TIMEOUT
static final Duration	DEFAULT_SOCKET_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
OpenSearchRestClientFactory()

Method Summary

Modifier and Type	Method	Description
protected void	checkConnection(String clientId, org.opensearch.client.RestHighLevelClient client)
OpenSearchClient	create(OpenSearchClientConfig config)
protected OpenSearchClient	createRestClient(OpenSearchClientConfig config)
protected org.apache.http.impl.client.BasicCredentialsProvider	getCredentialProvider(OpenSearchClientConfig config)
protected SSLContext	getSslContext(OpenSearchClientConfig config)
protected KeyStore	loadKeyStore(OpenSearchClientConfig.Store storeConfig)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_CONNECT_TIMEOUT

public static final Duration DEFAULT_CONNECT_TIMEOUT

DEFAULT_SOCKET_TIMEOUT

public static final Duration DEFAULT_SOCKET_TIMEOUT

Constructor Details

OpenSearchRestClientFactory

public OpenSearchRestClientFactory()

Method Details

create

public OpenSearchClient create(OpenSearchClientConfig config)

Specified by:

create in interface OpenSearchClientFactory

createRestClient

protected OpenSearchClient createRestClient(OpenSearchClientConfig config)

getCredentialProvider

protected org.apache.http.impl.client.BasicCredentialsProvider getCredentialProvider(OpenSearchClientConfig config)

getSslContext

protected SSLContext getSslContext(OpenSearchClientConfig config)

loadKeyStore

protected KeyStore loadKeyStore(OpenSearchClientConfig.Store storeConfig)
                         throws GeneralSecurityException,
IOException

Throws:

GeneralSecurityException

IOException

checkConnection

protected void checkConnection(String clientId,
 org.opensearch.client.RestHighLevelClient client)