org.graylog2.indexer

Class Deflector

java.lang.Object

org.graylog2.indexer.Deflector

public class Deflector
extends java.lang.Object

Format of actual indexes behind the Deflector: [configured_prefix]_1 [configured_prefix]_2 [configured_prefix]_3 ...

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFLECTOR_SUFFIX
static java.lang.String	SEPARATOR

Constructor Summary

Constructors

Constructor and Description
Deflector(SystemJobManager systemJobManager, Configuration configuration, ActivityWriter activityWriter, RebuildIndexRangesJob.Factory rebuildIndexRangesJobFactory, OptimizeIndexJob.Factory optimizeIndexJobFactory, CreateNewSingleIndexRangeJob.Factory createNewSingleIndexRangeJobFactory, Indices indices)

Method Summary

Modifier and Type	Method and Description
static java.lang.String	buildIndexName(java.lang.String prefix, int number)
static java.lang.String	buildName(java.lang.String prefix)
void	cycle()
static int	extractIndexNumber(java.lang.String indexName)
java.lang.String[]	getAllDeflectorIndexNames()
java.util.Map<java.lang.String,org.elasticsearch.action.admin.indices.stats.IndexStats>	getAllDeflectorIndices()
java.lang.String	getCurrentActualTargetIndex()
java.lang.String	getName()
java.lang.String	getNewestTargetName()
int	getNewestTargetNumber()
boolean	isDeflectorAlias(java.lang.String indexName)
boolean	isGraylog2Index(java.lang.String indexName)
boolean	isUp()
void	pointTo(java.lang.String newIndex)
void	pointTo(java.lang.String newIndex, java.lang.String oldIndex)
void	setUp()

Methods inherited from class java.lang.Object

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

Field Detail

DEFLECTOR_SUFFIX

public static final java.lang.String DEFLECTOR_SUFFIX

See Also:

Constant Field Values

SEPARATOR

public static final java.lang.String SEPARATOR

See Also:

Constant Field Values

Constructor Detail

Deflector

@Inject
public Deflector(SystemJobManager systemJobManager,
                         Configuration configuration,
                         ActivityWriter activityWriter,
                         RebuildIndexRangesJob.Factory rebuildIndexRangesJobFactory,
                         OptimizeIndexJob.Factory optimizeIndexJobFactory,
                         CreateNewSingleIndexRangeJob.Factory createNewSingleIndexRangeJobFactory,
                         Indices indices)

Method Detail

isUp

public boolean isUp()

setUp

public void setUp()

cycle

public void cycle()

getNewestTargetNumber

public int getNewestTargetNumber()
                          throws NoTargetIndexException

Throws:

NoTargetIndexException

getAllDeflectorIndexNames

public java.lang.String[] getAllDeflectorIndexNames()

getAllDeflectorIndices

public java.util.Map<java.lang.String,org.elasticsearch.action.admin.indices.stats.IndexStats> getAllDeflectorIndices()

getNewestTargetName

public java.lang.String getNewestTargetName()
                                     throws NoTargetIndexException

Throws:

NoTargetIndexException

buildIndexName

public static java.lang.String buildIndexName(java.lang.String prefix,
                                              int number)

buildName

public static java.lang.String buildName(java.lang.String prefix)

extractIndexNumber

public static int extractIndexNumber(java.lang.String indexName)
                              throws java.lang.NumberFormatException

Throws:

java.lang.NumberFormatException

pointTo

public void pointTo(java.lang.String newIndex,
                    java.lang.String oldIndex)

pointTo

public void pointTo(java.lang.String newIndex)

getCurrentActualTargetIndex

public java.lang.String getCurrentActualTargetIndex()

getName

public java.lang.String getName()

isDeflectorAlias

public boolean isDeflectorAlias(java.lang.String indexName)

isGraylog2Index

public boolean isGraylog2Index(java.lang.String indexName)