org.graylog2.indexer.indices

Class Indices

java.lang.Object

org.graylog2.indexer.indices.Indices

All Implemented Interfaces:

IndexManagement

@Singleton
public class Indices
extends Object
implements IndexManagement

Constructor Summary

Constructors

Constructor and Description
Indices(org.elasticsearch.client.Client client, ElasticsearchConfiguration configuration, IndexMapping indexMapping)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	aliasExists(String alias)
String	aliasTarget(String alias)
String	allIndicesAlias()
protected Boolean	checkForReopened(org.elasticsearch.cluster.metadata.IndexMetaData metaData)
void	close(String indexName)
boolean	create(String indexName)
boolean	cycleAlias(String aliasName, String targetIndex)
boolean	cycleAlias(String aliasName, String targetIndex, String oldIndex)
void	delete(String indexName)
boolean	exists(String index)
void	flush(String index)
Map<String,org.elasticsearch.action.admin.indices.stats.IndexStats>	getAll()
Set<String>	getAllMessageFields()
Set<String>	getClosedIndices()
IndexStatistics	getIndexStats(String index)
Set<String>	getReopenedIndices()
org.joda.time.DateTime	indexCreationDate(String index)
boolean	isReadOnly(String index)
boolean	isReopened(String indexName)
void	move(String source, String target)
long	numberOfMessages(String indexName)
void	optimizeIndex(String index)
void	reopenIndex(String index)
void	setReadOnly(String index)
void	setReadWrite(String index)
org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus	waitForRecovery(String index)
org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus	waitForStatus(String index, org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus clusterHealthStatus)

Methods inherited from class java.lang.Object

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

Constructor Detail

Indices

@Inject
public Indices(org.elasticsearch.client.Client client,
              ElasticsearchConfiguration configuration,
              IndexMapping indexMapping)

Method Detail

move

public void move(String source,
        String target)

delete

public void delete(String indexName)

Specified by:

delete in interface IndexManagement

close

public void close(String indexName)

Specified by:

close in interface IndexManagement

numberOfMessages

public long numberOfMessages(String indexName)
                      throws IndexNotFoundException

Throws:

IndexNotFoundException

getAll

public Map<String,org.elasticsearch.action.admin.indices.stats.IndexStats> getAll()

allIndicesAlias

public String allIndicesAlias()

exists

public boolean exists(String index)

aliasExists

public boolean aliasExists(String alias)

aliasTarget

@Nullable
public String aliasTarget(String alias)

create

public boolean create(String indexName)

getAllMessageFields

public Set<String> getAllMessageFields()

setReadOnly

public void setReadOnly(String index)

isReadOnly

public boolean isReadOnly(String index)

setReadWrite

public void setReadWrite(String index)

flush

public void flush(String index)

reopenIndex

public void reopenIndex(String index)

isReopened

public boolean isReopened(String indexName)

checkForReopened

protected Boolean checkForReopened(org.elasticsearch.cluster.metadata.IndexMetaData metaData)

getClosedIndices

public Set<String> getClosedIndices()

getReopenedIndices

public Set<String> getReopenedIndices()

getIndexStats

public IndexStatistics getIndexStats(String index)

cycleAlias

public boolean cycleAlias(String aliasName,
                 String targetIndex)

cycleAlias

public boolean cycleAlias(String aliasName,
                 String targetIndex,
                 String oldIndex)

optimizeIndex

public void optimizeIndex(String index)

waitForRecovery

public org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus waitForRecovery(String index)

waitForStatus

public org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus waitForStatus(String index,
                                                                              org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus clusterHealthStatus)

indexCreationDate

@Nullable
public org.joda.time.DateTime indexCreationDate(String index)