Class TransportElasticSearchConnector
- java.lang.Object
-
- io.vertigo.connectors.elasticsearch.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
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.elasticsearch.common.settings.SettingsbuildNodeSettings()org.elasticsearch.client.ClientgetClient()StringgetName()voidstart()voidstop()
-
-
-
Constructor Detail
-
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 à rejoindrenodeNameOpt- : nom du node
-
-
Method Detail
-
start
public void start()
- Specified by:
startin interfaceio.vertigo.core.node.component.Activeable
-
getName
public String getName()
- Specified by:
getNamein interfaceio.vertigo.core.node.component.Connector<org.elasticsearch.client.Client>
-
getClient
public org.elasticsearch.client.Client getClient()
- Specified by:
getClientin interfaceio.vertigo.core.node.component.Connector<org.elasticsearch.client.Client>
-
stop
public void stop()
- Specified by:
stopin interfaceio.vertigo.core.node.component.Activeable
-
buildNodeSettings
protected org.elasticsearch.common.settings.Settings buildNodeSettings()
-
-