org.openecomp.sdc.be.dao.es

Class ElasticSearchClient

java.lang.Object

org.openecomp.sdc.be.dao.es.ElasticSearchClient

@Component(value="elasticsearch-client")
public class ElasticSearchClient
extends Object

Prepare the node to work with elastic search.

Author:

luc boutier

Constructor Summary

Constructors

Constructor and Description
ElasticSearchClient()

Method Summary

Modifier and Type	Method and Description
void	close()
org.elasticsearch.client.Client	getClient() Get the elastic search client.
String	getServerHost()
String	getServerPort()
void	initialize()
boolean	isTransportClient()
void	setClusterName(String clusterName)
void	setLocal(String strIsLocal)
void	setTransportClient(String strIsTransportclient)
org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse	waitForGreenStatus(String... indices) Wait for green status for the given indices.

Methods inherited from class java.lang.Object

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

Constructor Detail

ElasticSearchClient

public ElasticSearchClient()

Method Detail

initialize

@PostConstruct
public void initialize()
                               throws URISyntaxException

Throws:

URISyntaxException

close

@PreDestroy
public void close()

getClient

public org.elasticsearch.client.Client getClient()

Get the elastic search client.

Returns:

The elastic search client.

getServerHost

public String getServerHost()

getServerPort

public String getServerPort()

waitForGreenStatus

public org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse waitForGreenStatus(String... indices)

Wait for green status for the given indices.

Parameters:

indices - The indices to wait for.

Returns:

A ClusterHealthResponse that contains the cluster health after waiting maximum 5 minutes for green status.

setClusterName

@Value(value="#{elasticsearchConfig[\'cluster.name\']}")
public void setClusterName(String clusterName)

setLocal

@Value(value="#{elasticsearchConfig[\'elasticSearch.local\']}")
public void setLocal(String strIsLocal)

isTransportClient

public boolean isTransportClient()

setTransportClient

@Value(value="#{elasticsearchConfig[\'elasticSearch.transportclient\']}")
public void setTransportClient(String strIsTransportclient)