@Name(value="esAdmin") @Scope(value=EVENT) public class ElasticSearchManager extends Object
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 and Description |
---|
ElasticSearchManager() |
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() |
@In(create=true) protected ElasticSearchAdmin esa
@In(create=true) protected ElasticSearchIndexing esi
@In(create=true, required=false) protected transient CoreSession documentManager
protected List<PageProviderStatus> ppStatuses
protected com.codahale.metrics.Timer indexTimer
protected com.codahale.metrics.Timer bulkIndexTimer
public ElasticSearchManager()
public String getNodesInfo()
public String getNodesStats()
public String getNodesHealth()
public void startReindexAll()
public void startReindexNxql()
public void startReindexFrom()
public void flush()
public void optimize()
protected void introspectPageProviders()
public List<PageProviderStatus> getContentViewStatus()
public Boolean isIndexingInProgress()
public Boolean displayClusterInfo()
public String getPendingWorkerCount()
public String getRunningWorkerCount()
public String getTotalCommandProcessed()
public String getNumberOfDocuments()
public String getIndexingRates()
public String getBulkIndexingRates()
public List<String> getRepositoryNames()
public String getRepositoryName()
public void setRepositoryName(String repositoryName)
public Boolean getDropIndex()
public void setDropIndex(Boolean dropIndex)
Copyright © 2015 Nuxeo SA. All rights reserved.