Package io.vertigo.connectors.elasticsearch_7_17

Class TransportElasticSearchConnector

java.lang.Object

io.vertigo.connectors.elasticsearch_7_17.TransportElasticSearchConnector

All Implemented Interfaces:

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

public class TransportElasticSearchConnector
extends Object
implements ElasticSearchConnector

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
TransportElasticSearchConnector(Optional<String> connectorNameOpt, String serversNamesStr, String clusterName, Optional<String> nodeNameOpt)	Constructor.

Method Summary

Modifier and Type	Method	Description
protected org.elasticsearch.common.settings.Settings	buildNodeSettings()
org.elasticsearch.client.Client	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

TransportElasticSearchConnector

@Inject
public TransportElasticSearchConnector(Optional<String> connectorNameOpt,
 String serversNamesStr,
 String clusterName,
 Optional<String> nodeNameOpt)

Constructor.

Parameters:

serversNamesStr - URL du serveur ElasticSearch avec le port de communication de cluster (9300 en général)

clusterName - : nom du cluster à rejoindre

nodeNameOpt - : nom du node

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.Client>

getClient

public org.elasticsearch.client.Client getClient()

Specified by:

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

stop

public void stop()

Specified by:

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

buildNodeSettings

protected org.elasticsearch.common.settings.Settings buildNodeSettings()