org.adroitlogic.x.metrics

Class ESStatisticsPublisher

java.lang.Object

org.adroitlogic.x.metrics.ESStatisticsPublisher

All Implemented Interfaces:

XStatisticsPublisher<org.elasticsearch.common.xcontent.XContentBuilder>

public class ESStatisticsPublisher
extends Object
implements XStatisticsPublisher<org.elasticsearch.common.xcontent.XContentBuilder>

ElasticSearch based statistics publisher

Since:

17.01

Author:

Ruwan Linton, Manjula, Udith Gunaratna

Constructor Summary

Constructors

Constructor and Description
ESStatisticsPublisher(ESStatisticsServer esStatisticsServer)

Method Summary

Modifier and Type	Method and Description
void	destroy()
void	init(String confDir)
void	publish(Map<String,Object> contentMap) Publishes a map of contents to external metrics collector
void	publish(String contentString) Publishes a string contents to external metrics collector
void	publish(org.elasticsearch.common.xcontent.XContentBuilder content) Publishes T type contents to external metrics collector
void	setActiveIndexAliasName(String activeIndexAliasName)
void	setBackOffExponentialRetryAttempts(int backOffExponentialRetryAttempts)
void	setBackOffExponentialTimeInMillis(int backOffExponentialTimeInMillis)
void	setBulkActions(int bulkActions)
void	setBulkSizeInMB(int bulkSizeInMB)
void	setConcurrentRequests(int concurrentRequests)
void	setDeleteInactiveIndicesAtDestroy(boolean deleteInactiveIndicesAtDestroy)
void	setDeleteInactiveIndicesAtInit(boolean deleteInactiveIndicesAtInit)
void	setDeleteOldestIndexAfterRollOver(boolean deleteOldestIndexAfterRollOver)
void	setEsHealthTimeoutMillis(int esHealthTimeoutMillis)
void	setFlushIntervalInSeconds(int flushIntervalInSeconds)
void	setInactiveIndexAliasName(String inactiveIndexAliasName)
void	setInactiveSettingFile(String inactiveSettingFile)
void	setIndexMappingType(String indexMappingType)
void	setIndexRollOverEnabled(boolean indexRollOverEnabled)
void	setIndexTemplateName(String indexTemplateName)
void	setInitialIndexName(String initialIndexName)
void	setMaxAgeInMinutes(long maxAgeInMinutes)
void	setMaxDocs(long maxDocs)
void	setOptimized(boolean optimized)
void	setRollOverTimePeriodInMinutes(long rollOverTimePeriodInMinutes)
void	setTemplateFile(String templateFile)

Methods inherited from class java.lang.Object

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

Constructor Detail

ESStatisticsPublisher

public ESStatisticsPublisher(ESStatisticsServer esStatisticsServer)

Method Detail

init

public void init(String confDir)

Specified by:

init in interface XStatisticsPublisher<org.elasticsearch.common.xcontent.XContentBuilder>

destroy

public void destroy()

Specified by:

destroy in interface XStatisticsPublisher<org.elasticsearch.common.xcontent.XContentBuilder>

publish

public void publish(Map<String,Object> contentMap)

Publishes a map of contents to external metrics collector

Specified by:

publish in interface XStatisticsPublisher<org.elasticsearch.common.xcontent.XContentBuilder>

Parameters:

contentMap - key-value pairs of metrics records

publish

public void publish(String contentString)

Publishes a string contents to external metrics collector

Specified by:

publish in interface XStatisticsPublisher<org.elasticsearch.common.xcontent.XContentBuilder>

Parameters:

contentString - string of metrics records

publish

public void publish(org.elasticsearch.common.xcontent.XContentBuilder content)

Publishes T type contents to external metrics collector

Specified by:

publish in interface XStatisticsPublisher<org.elasticsearch.common.xcontent.XContentBuilder>

Parameters:

content - metrics record content

setBulkActions

public void setBulkActions(int bulkActions)

setBulkSizeInMB

public void setBulkSizeInMB(int bulkSizeInMB)

setFlushIntervalInSeconds

public void setFlushIntervalInSeconds(int flushIntervalInSeconds)

setConcurrentRequests

public void setConcurrentRequests(int concurrentRequests)

setBackOffExponentialTimeInMillis

public void setBackOffExponentialTimeInMillis(int backOffExponentialTimeInMillis)

setBackOffExponentialRetryAttempts

public void setBackOffExponentialRetryAttempts(int backOffExponentialRetryAttempts)

setEsHealthTimeoutMillis

public void setEsHealthTimeoutMillis(int esHealthTimeoutMillis)

setOptimized

public void setOptimized(boolean optimized)

setInitialIndexName

public void setInitialIndexName(String initialIndexName)

setIndexMappingType

public void setIndexMappingType(String indexMappingType)

setIndexTemplateName

public void setIndexTemplateName(String indexTemplateName)

setActiveIndexAliasName

public void setActiveIndexAliasName(String activeIndexAliasName)

setInactiveIndexAliasName

public void setInactiveIndexAliasName(String inactiveIndexAliasName)

setMaxDocs

public void setMaxDocs(long maxDocs)

setMaxAgeInMinutes

public void setMaxAgeInMinutes(long maxAgeInMinutes)

setRollOverTimePeriodInMinutes

public void setRollOverTimePeriodInMinutes(long rollOverTimePeriodInMinutes)

setIndexRollOverEnabled

public void setIndexRollOverEnabled(boolean indexRollOverEnabled)

setTemplateFile

public void setTemplateFile(String templateFile)

setInactiveSettingFile

public void setInactiveSettingFile(String inactiveSettingFile)

setDeleteOldestIndexAfterRollOver

public void setDeleteOldestIndexAfterRollOver(boolean deleteOldestIndexAfterRollOver)

setDeleteInactiveIndicesAtInit

public void setDeleteInactiveIndicesAtInit(boolean deleteInactiveIndicesAtInit)

setDeleteInactiveIndicesAtDestroy

public void setDeleteInactiveIndicesAtDestroy(boolean deleteInactiveIndicesAtDestroy)