Package io.vertigo.connectors.elasticsearch

Class RestElasticSearchConnector

java.lang.Object

io.vertigo.connectors.elasticsearch.RestElasticSearchConnector

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.Connector<co.elastic.clients.elasticsearch.ElasticsearchClient>, io.vertigo.core.node.component.CoreComponent

public class RestElasticSearchConnector
extends Object
implements io.vertigo.core.node.component.Connector<co.elastic.clients.elasticsearch.ElasticsearchClient>, io.vertigo.core.node.component.Activeable

Gestion de la connexion au serveur elasticSearch en mode HTTP.

Author:

npiedeloup, mlaroche

Field Summary

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

DEFAULT_CONNECTOR_NAME

Constructor Summary

Constructors

Constructor	Description
RestElasticSearchConnector(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<String> trustStoreUrlOpt, Optional<String> trustStorePasswordOpt)	Constructor.

Method Summary

Modifier and Type	Method	Description
protected co.elastic.clients.transport.ElasticsearchTransportConfig.Builder	buildRestClientBuilder(co.elastic.clients.transport.ElasticsearchTransportConfig.Builder builder, 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)
co.elastic.clients.elasticsearch.ElasticsearchClient	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

RestElasticSearchConnector

@Inject
public RestElasticSearchConnector(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<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<co.elastic.clients.elasticsearch.ElasticsearchClient>

getClient

public co.elastic.clients.elasticsearch.ElasticsearchClient getClient()

Specified by:

getClient in interface io.vertigo.core.node.component.Connector<co.elastic.clients.elasticsearch.ElasticsearchClient>

stop

public void stop()

Specified by:

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

buildRestClientBuilder

protected co.elastic.clients.transport.ElasticsearchTransportConfig.Builder buildRestClientBuilder(co.elastic.clients.transport.ElasticsearchTransportConfig.Builder builder,
 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)