org.graylog2.indexer.indices

Class Indices

java.lang.Object

org.graylog2.indexer.indices.Indices

@Singleton
public class Indices
extends Object

Constructor Summary

Constructors

Constructor and Description
Indices(org.elasticsearch.client.Client client, IndexMapping indexMapping, Messages messages, NodeId nodeId, AuditEventSender auditEventSender)

Method Summary

Modifier and Type	Method and Description
boolean	aliasExists(String alias)
String	aliasTarget(String alias)
Map<String,Boolean>	areReopened(Collection<String> indices)
void	close(String indexName)
boolean	create(String indexName, IndexSet indexSet)
boolean	create(String indexName, IndexSet indexSet, org.elasticsearch.common.settings.Settings customSettings)
boolean	cycleAlias(String aliasName, String targetIndex)
boolean	cycleAlias(String aliasName, String targetIndex, String oldIndex)
void	delete(String indexName)
void	deleteIndexTemplate(IndexSet indexSet)
boolean	exists(String index)
void	flush(String index)
Map<String,org.elasticsearch.action.admin.indices.stats.IndexStats>	getAll(IndexSet indexSet)
Map<String,org.elasticsearch.action.admin.indices.stats.IndexStats>	getAllDocCounts(IndexSet indexSet)
Set<String>	getAllMessageFields(String[] writeIndexWildcards)
Map<String,Set<String>>	getAllMessageFieldsForIndices(String[] writeIndexWildcards)
Set<String>	getClosedIndices(IndexSet indexSet)
Map<String,Set<String>>	getIndexNamesAndAliases(String indexPattern)
IndexStatistics	getIndexStats(String index)
Set<IndexStatistics>	getIndicesStats(IndexSet indexSet)
Set<String>	getReopenedIndices(IndexSet indexSet)
org.joda.time.DateTime	indexCreationDate(String index)
IndexRangeStats	indexRangeStatsOfIndex(String index) Calculate min and max message timestamps in the given index.
org.elasticsearch.action.admin.indices.stats.IndexStats	indexStats(String indexName)
boolean	isReopened(String indexName)
void	move(String source, String target)
long	numberOfMessages(String indexName)
void	optimizeIndex(String index, int maxNumSegments, com.github.joschi.jadconfig.util.Duration timeout)
boolean	removeAliases(String alias, Set<String> indices)
void	reopenIndex(String index)
org.elasticsearch.common.settings.Settings	reopenIndexSettings()
void	setReadOnly(String index)
org.elasticsearch.cluster.health.ClusterHealthStatus	waitForRecovery(String index)
org.elasticsearch.cluster.health.ClusterHealthStatus	waitForStatus(String index, org.elasticsearch.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,
                       IndexMapping indexMapping,
                       Messages messages,
                       NodeId nodeId,
                       AuditEventSender auditEventSender)

Method Detail

move

public void move(String source,
                 String target)

delete

public void delete(String indexName)

close

public void close(String indexName)

numberOfMessages

public long numberOfMessages(String indexName)
                      throws IndexNotFoundException

Throws:

IndexNotFoundException

getAll

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

getAllDocCounts

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

indexStats

@Nullable
public org.elasticsearch.action.admin.indices.stats.IndexStats indexStats(String indexName)

exists

public boolean exists(String index)

aliasExists

public boolean aliasExists(String alias)

getIndexNamesAndAliases

@NotNull
public Map<String,Set<String>> getIndexNamesAndAliases(String indexPattern)

aliasTarget

@Nullable
public String aliasTarget(String alias)
                             throws TooManyAliasesException

Throws:

TooManyAliasesException

deleteIndexTemplate

public void deleteIndexTemplate(IndexSet indexSet)

create

public boolean create(String indexName,
                      IndexSet indexSet)

create

public boolean create(String indexName,
                      IndexSet indexSet,
                      org.elasticsearch.common.settings.Settings customSettings)

getAllMessageFieldsForIndices

public Map<String,Set<String>> getAllMessageFieldsForIndices(String[] writeIndexWildcards)

getAllMessageFields

public Set<String> getAllMessageFields(String[] writeIndexWildcards)

setReadOnly

public void setReadOnly(String index)

flush

public void flush(String index)

reopenIndexSettings

public org.elasticsearch.common.settings.Settings reopenIndexSettings()

reopenIndex

public void reopenIndex(String index)

isReopened

public boolean isReopened(String indexName)

areReopened

public Map<String,Boolean> areReopened(Collection<String> indices)

getClosedIndices

public Set<String> getClosedIndices(IndexSet indexSet)

getReopenedIndices

public Set<String> getReopenedIndices(IndexSet indexSet)

getIndexStats

@Nullable
public IndexStatistics getIndexStats(String index)

getIndicesStats

public Set<IndexStatistics> getIndicesStats(IndexSet indexSet)

cycleAlias

public boolean cycleAlias(String aliasName,
                          String targetIndex)

cycleAlias

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

removeAliases

public boolean removeAliases(String alias,
                             Set<String> indices)

optimizeIndex

public void optimizeIndex(String index,
                          int maxNumSegments,
                          com.github.joschi.jadconfig.util.Duration timeout)

waitForRecovery

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

waitForStatus

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

indexCreationDate

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

indexRangeStatsOfIndex

public IndexRangeStats indexRangeStatsOfIndex(String index)

Calculate min and max message timestamps in the given index.

Parameters:

index - Name of the index to query.

Returns:

the timestamp stats in the given index, or null if they couldn't be calculated.

See Also:

Stats