Package io.vertigo.connectors.elasticsearch

Class SecuredTransportSearchConnector

java.lang.Object

io.vertigo.connectors.elasticsearch.SecuredTransportSearchConnector

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 SecuredTransportSearchConnector
extends Object
implements ElasticSearchConnector

Gestion de la connexion au serveur elasticSearch en mode TCP + SSL. Utilisation du client Transport simple, sans intégration au cluster (permet de ne pas avoir de liaison bi-directionelle entre le tomcat et l'ES externe).

Author:

skerdudou

Field Summary

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

DEFAULT_CONNECTOR_NAME

Constructor Summary

Constructors

Constructor

Description

SecuredTransportSearchConnector(Optional<String> connectorNameOpt, String serversNamesStr, String envIndex, Optional<Boolean> envIndexIsPrefix, int rowsPerQuery, String clusterName, String configFile, Optional<String> nodeNameOpt, Optional<Boolean> securityEnabled, Optional<String> securityUser, Optional<String> securityPassword, Optional<String> securityKey, Optional<String> securityKeyPassPhrase, Optional<String> securityCertificate)

Constructor.

Method Summary

Modifier and Type	Method	Description
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 Detail

SecuredTransportSearchConnector

@Inject
public SecuredTransportSearchConnector(Optional<String> connectorNameOpt,
                                       String serversNamesStr,
                                       String envIndex,
                                       Optional<Boolean> envIndexIsPrefix,
                                       int rowsPerQuery,
                                       String clusterName,
                                       String configFile,
                                       Optional<String> nodeNameOpt,
                                       Optional<Boolean> securityEnabled,
                                       Optional<String> securityUser,
                                       Optional<String> securityPassword,
                                       Optional<String> securityKey,
                                       Optional<String> securityKeyPassPhrase,
                                       Optional<String> securityCertificate)

Constructor.

Parameters:

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

envIndex - Nom de l'index de l'environment

envIndexIsPrefix - Si Nom de l'index de l'environment est un prefix

rowsPerQuery - Liste des indexes

clusterName - : nom du cluster à rejoindre

nodeNameOpt - : nom du node

securityEnabled - active ou non la sécurité

securityUser - l'utilisateur ES

securityKey - la clé privé (si chiffrée doit être en AES)

securityKeyPassPhrase - passphrase si clé chiffrée

securityCertificate - le certificat

configFile - fichier de configuration des index

Method Detail

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