Package io.vertigo.connectors.elasticsearch_7_17

Class RestHighLevelElasticSearchConnector

java.lang.Object

io.vertigo.connectors.elasticsearch_7_17.RestHighLevelElasticSearchConnector

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.Connector<org.elasticsearch.client.RestHighLevelClient>, io.vertigo.core.node.component.CoreComponent

public class RestHighLevelElasticSearchConnector
extends Object
implements io.vertigo.core.node.component.Connector<org.elasticsearch.client.RestHighLevelClient>, io.vertigo.core.node.component.Activeable

Gestion de la connexion au serveur elasticSearch en mode HTTP.

Author:

npiedeloup

Field Summary

Fields inherited from interface io.vertigo.core.node.component.Connector

DEFAULT_CONNECTOR_NAME

Constructor Summary

Constructors

Constructor

Description

RestHighLevelElasticSearchConnector(io.vertigo.core.resource.ResourceManager resourceManager, Optional<String> connectorNameOpt, String serversNamesStr, Optional<String> basicUserOpt, Optional<String> basicPasswordOpt, Optional<String> apiKeyIdOpt, Optional<String> apiKeySecretOpt, boolean ssl, Optional<Boolean> compatibilityMode, Optional<String> trustStoreUrlOpt, Optional<String> trustStorePasswordOpt)

Constructor.

Method Summary

Modifier and Type	Method	Description
protected org.elasticsearch.client.RestClientBuilder	buildRestClientBuilder(io.vertigo.core.resource.ResourceManager resourceManager, Optional<String> basicUserOpt, Optional<String> basicPasswordOpt, Optional<String> apiKeyIdOpt, Optional<String> apiKeySecretOpt, boolean ssl, Optional<String> trustStoreUrlOpt, Optional<String> trustStorePasswordOpt)
org.elasticsearch.client.RestHighLevelClient	getClient()
String	getName()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

RestHighLevelElasticSearchConnector

@Inject
public RestHighLevelElasticSearchConnector(io.vertigo.core.resource.ResourceManager resourceManager,
 Optional<String> connectorNameOpt,
 String serversNamesStr,
 Optional<String> basicUserOpt,
 Optional<String> basicPasswordOpt,
 Optional<String> apiKeyIdOpt,
 Optional<String> apiKeySecretOpt,
 boolean ssl,
 Optional<Boolean> compatibilityMode,
 Optional<String> trustStoreUrlOpt,
 Optional<String> trustStorePasswordOpt)

Constructor.

Parameters:

resourceManager - Resource manager

connectorNameOpt - Connector name (default `main`)

serversNamesStr - Server names list (ex : host1:3889,host2:3889) separator : ','

basicUserOpt - Username if basic autgent

basicPasswordOpt - password if basic authent

apiKeyIdOpt - api key id if apiKey authent

apiKeySecretOpt - api key secret if apiKey authent

ssl - if using ssl

trustStoreUrlOpt - Url to truststore

trustStorePasswordOpt - truststore's password

Method Details

start

public void start()

Specified by:

start in interface io.vertigo.core.node.component.Activeable

getName

public String getName()

Specified by:

getName in interface io.vertigo.core.node.component.Connector<org.elasticsearch.client.RestHighLevelClient>

getClient

public org.elasticsearch.client.RestHighLevelClient getClient()

Specified by:

getClient in interface io.vertigo.core.node.component.Connector<org.elasticsearch.client.RestHighLevelClient>

stop

public void stop()

Specified by:

stop in interface io.vertigo.core.node.component.Activeable

buildRestClientBuilder

protected org.elasticsearch.client.RestClientBuilder buildRestClientBuilder(io.vertigo.core.resource.ResourceManager resourceManager,
 Optional<String> basicUserOpt,
 Optional<String> basicPasswordOpt,
 Optional<String> apiKeyIdOpt,
 Optional<String> apiKeySecretOpt,
 boolean ssl,
 Optional<String> trustStoreUrlOpt,
 Optional<String> trustStorePasswordOpt)