org.nuxeo.elasticsearch.web.admin

Class ElasticSearchManager

java.lang.Object

org.nuxeo.elasticsearch.web.admin.ElasticSearchManager

All Implemented Interfaces:

Serializable

@Name(value="esAdmin")
 @Scope(value=CONVERSATION)
public class ElasticSearchManager
extends Object
implements Serializable

Author:

Tiry

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected com.codahale.metrics.Timer	bulkIndexTimer
protected CoreSession	documentManager
protected ElasticSearchAdmin	esa
protected ElasticSearchIndexing	esi
protected com.codahale.metrics.Timer	indexTimer
protected List<PageProviderStatus>	ppStatuses

Constructor Summary

Constructors

Constructor and Description
ElasticSearchManager()

Method Summary

Modifier and Type	Method and Description
Boolean	displayClusterInfo()
void	flush()
String	getBulkIndexingRates()
List<PageProviderStatus>	getContentViewStatus()
Boolean	getDropIndex()
String	getIndexingRates()
String	getNodesHealth()
String	getNodesInfo()
String	getNodesStats()
String	getNumberOfDocuments()
String	getNxql()
String	getPendingWorkerCount()
String	getRepositoryName()
List<String>	getRepositoryNames()
String	getRootId()
String	getRunningWorkerCount()
String	getTotalCommandProcessed()
protected void	introspectPageProviders()
Boolean	isIndexingInProgress()
void	optimize()
void	setDropIndex(Boolean dropIndex)
void	setNxql(String nxql)
void	setRepositoryName(String repositoryName)
void	setRootId(String rootId)
void	startReindexAll()
void	startReindexFrom()
void	startReindexNxql()

Methods inherited from class java.lang.Object

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

Field Detail

esa

@In(create=true)
protected ElasticSearchAdmin esa

esi

@In(create=true)
protected ElasticSearchIndexing esi

documentManager

@In(create=true,
    required=false)
protected transient CoreSession documentManager

ppStatuses

protected List<PageProviderStatus> ppStatuses

indexTimer

protected com.codahale.metrics.Timer indexTimer

bulkIndexTimer

protected com.codahale.metrics.Timer bulkIndexTimer

Constructor Detail

ElasticSearchManager

public ElasticSearchManager()

Method Detail

getNodesInfo

public String getNodesInfo()

getNodesStats

public String getNodesStats()

getNodesHealth

public String getNodesHealth()

startReindexAll

public void startReindexAll()

startReindexNxql

public void startReindexNxql()

startReindexFrom

public void startReindexFrom()

flush

public void flush()

optimize

public void optimize()

introspectPageProviders

protected void introspectPageProviders()

getContentViewStatus

public List<PageProviderStatus> getContentViewStatus()

isIndexingInProgress

public Boolean isIndexingInProgress()

displayClusterInfo

public Boolean displayClusterInfo()

getPendingWorkerCount

public String getPendingWorkerCount()

getRunningWorkerCount

public String getRunningWorkerCount()

getTotalCommandProcessed

public String getTotalCommandProcessed()

getNumberOfDocuments

public String getNumberOfDocuments()

getIndexingRates

public String getIndexingRates()

getBulkIndexingRates

public String getBulkIndexingRates()

getRootId

public String getRootId()

getRepositoryNames

public List<String> getRepositoryNames()

setRootId

public void setRootId(String rootId)

getNxql

public String getNxql()

setNxql

public void setNxql(String nxql)

getRepositoryName

public String getRepositoryName()

setRepositoryName

public void setRepositoryName(String repositoryName)

getDropIndex

public Boolean getDropIndex()

setDropIndex

public void setDropIndex(Boolean dropIndex)