org.adroitlogic.x.metrics

Class ExternalElasticsearchServer

java.lang.Object

org.adroitlogic.x.metrics.ExternalElasticsearchServer

All Implemented Interfaces:

ESStatisticsServer

public class ExternalElasticsearchServer
extends Object
implements ESStatisticsServer

Implementation of the external Elasticsearch statistics server. This implementation used ESMinTransportClient which only have Netty4Plugin pre-installed. In order to use additional plugins, required libraries must be added to the classpath and following property set must be specified in spring configuration.

 <property name="classpathPlugins">
      <list>
          <value>org.elasticsearch.transport.Netty3Plugin</value>
      </list>
 </property>
 

Since:

17.01

Author:

Udith Gunaratna

Constructor Summary

Constructors

Constructor and Description
ExternalElasticsearchServer()
ExternalElasticsearchServer(Map<String,Integer> addresses, String esClusterName)
ExternalElasticsearchServer(String esClusterName)

Method Summary

Modifier and Type	Method and Description
org.elasticsearch.client.Client	getClient() Retrieves the elasticsearch client to be used for connecting to the server
void	setClasspathPlugins(Collection<Class<? extends org.elasticsearch.plugins.Plugin>> classpathPlugins)
void	start(String confDir) Initializes the Statistics Server
void	stop() Destroys the Statistics Server

Methods inherited from class java.lang.Object

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

Constructor Detail

ExternalElasticsearchServer

public ExternalElasticsearchServer()

ExternalElasticsearchServer

public ExternalElasticsearchServer(String esClusterName)

ExternalElasticsearchServer

public ExternalElasticsearchServer(Map<String,Integer> addresses,
                                   String esClusterName)

Method Detail

setClasspathPlugins

public void setClasspathPlugins(Collection<Class<? extends org.elasticsearch.plugins.Plugin>> classpathPlugins)

start

public void start(String confDir)

Description copied from interface: ESStatisticsServer

Initializes the Statistics Server

Specified by:

start in interface ESStatisticsServer

Parameters:

confDir - Path of the base configuration directory to be used by this statistics server

getClient

public org.elasticsearch.client.Client getClient()

Description copied from interface: ESStatisticsServer

Retrieves the elasticsearch client to be used for connecting to the server

Specified by:

getClient in interface ESStatisticsServer

Returns:

Elasticsearch client

stop

public void stop()

Description copied from interface: ESStatisticsServer

Destroys the Statistics Server

Specified by:

stop in interface ESStatisticsServer