org.graylog2.indexer.indices

Interface IndicesAdapter

public interface IndicesAdapter

Method Summary

Modifier and Type	Method and Description
Map<String,Set<String>>	aliases(String indexPattern)
boolean	aliasExists(String alias)
void	close(String indexName)
Set<String>	closedIndices(Collection<String> indices)
void	create(String indexName, IndexSettings indexSettings, String templateName, Map<String,Object> template)
void	cycleAlias(String aliasName, String targetIndex)
void	cycleAlias(String aliasName, String targetIndex, String oldIndex)
void	delete(String indexName)
boolean	deleteIndexTemplate(String templateName)
boolean	ensureIndexTemplate(String templateName, Map<String,Object> template)
boolean	exists(String indexName)
Map<String,Set<String>>	fieldsInIndices(String[] writeIndexWildcards)
void	flush(String index)
com.fasterxml.jackson.databind.JsonNode	getIndexStats(Collection<String> index)
Optional<IndexStatistics>	getIndexStats(String index)
Optional<org.joda.time.DateTime>	indexCreationDate(String index)
IndexRangeStats	indexRangeStatsOfIndex(String index)
Set<String>	indices(String indexWildcard, List<String> status, String id)
Set<IndexStatistics>	indicesStats(Collection<String> indices)
boolean	isClosed(String index)
boolean	isOpen(String index)
void	markIndexReopened(String index)
void	move(String source, String target, Consumer<IndexMoveResult> resultCallback)
long	numberOfMessages(String indexName)
void	openIndex(String index)
void	optimizeIndex(String index, int maxNumSegments, com.github.joschi.jadconfig.util.Duration timeout)
void	removeAlias(String indexName, String alias)
void	removeAliases(Set<String> indices, String alias)
Set<String>	resolveAlias(String alias)
void	setReadOnly(String index)
Optional<Long>	storeSizeInBytes(String index)
void	updateIndexMapping(String indexName, String mappingType, Map<String,Object> mapping) Add fields to an existing index or to change search only settings of existing fields
HealthStatus	waitForRecovery(String index)
HealthStatus	waitForRecovery(String index, int timeout)

Method Detail

move

void move(String source,
          String target,
          Consumer<IndexMoveResult> resultCallback)

delete

void delete(String indexName)

resolveAlias

Set<String> resolveAlias(String alias)

create

void create(String indexName,
            IndexSettings indexSettings,
            String templateName,
            Map<String,Object> template)

updateIndexMapping

void updateIndexMapping(@Nonnull
                        String indexName,
                        @Nonnull
                        String mappingType,
                        @Nonnull
                        Map<String,Object> mapping)

Add fields to an existing index or to change search only settings of existing fields

Parameters:

indexName - existing index name

mappingType - target mapping type (e.g. message). Not relevant for ES7+ (will be simply ignored).

mapping - field mappings

ensureIndexTemplate

boolean ensureIndexTemplate(String templateName,
                            Map<String,Object> template)

indexCreationDate

Optional<org.joda.time.DateTime> indexCreationDate(String index)

openIndex

void openIndex(String index)

setReadOnly

void setReadOnly(String index)

flush

void flush(String index)

markIndexReopened

void markIndexReopened(String index)

removeAlias

void removeAlias(String indexName,
                 String alias)

close

void close(String indexName)

numberOfMessages

long numberOfMessages(String indexName)

aliasExists

boolean aliasExists(String alias)
             throws IOException

Throws:

IOException

aliases

Map<String,Set<String>> aliases(String indexPattern)

deleteIndexTemplate

boolean deleteIndexTemplate(String templateName)

fieldsInIndices

Map<String,Set<String>> fieldsInIndices(String[] writeIndexWildcards)

closedIndices

Set<String> closedIndices(Collection<String> indices)

indicesStats

Set<IndexStatistics> indicesStats(Collection<String> indices)

getIndexStats

Optional<IndexStatistics> getIndexStats(String index)

getIndexStats

com.fasterxml.jackson.databind.JsonNode getIndexStats(Collection<String> index)

exists

boolean exists(String indexName)
        throws IOException

Throws:

IOException

indices

Set<String> indices(String indexWildcard,
                    List<String> status,
                    String id)

storeSizeInBytes

Optional<Long> storeSizeInBytes(String index)

cycleAlias

void cycleAlias(String aliasName,
                String targetIndex)

cycleAlias

void cycleAlias(String aliasName,
                String targetIndex,
                String oldIndex)

removeAliases

void removeAliases(Set<String> indices,
                   String alias)

optimizeIndex

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

indexRangeStatsOfIndex

IndexRangeStats indexRangeStatsOfIndex(String index)

waitForRecovery

HealthStatus waitForRecovery(String index)

waitForRecovery

HealthStatus waitForRecovery(String index,
                             int timeout)

isOpen

boolean isOpen(String index)

isClosed

boolean isClosed(String index)