org.graylog2.indexer

Class Deflector

java.lang.Object

org.graylog2.indexer.Deflector

public class Deflector
extends Object

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

Author:

Lennart Koopmann

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFLECTOR_SUFFIX

Constructor Summary

Constructors

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

Method Summary

Methods

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

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 String DEFLECTOR_SUFFIX

See Also:

Constant Field Values

Constructor Detail

Deflector

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

Method Detail

isUp

public boolean isUp(Indexer indexer)

setUp

public void setUp(Indexer indexer)

cycle

public void cycle(Indexer indexer)

getNewestTargetNumber

public int getNewestTargetNumber(Indexer indexer)
                          throws NoTargetIndexException

Throws:

NoTargetIndexException

getAllDeflectorIndexNames

public String[] getAllDeflectorIndexNames(Indexer indexer)

getAllDeflectorIndices

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

getNewestTargetName

public String getNewestTargetName(Indexer indexer)
                           throws NoTargetIndexException

Throws:

NoTargetIndexException

buildIndexName

public static String buildIndexName(String prefix,
                    int number)

buildName

public static String buildName(String prefix)

extractIndexNumber

public static int extractIndexNumber(String indexName)
                              throws NumberFormatException

Throws:

NumberFormatException

pointTo

public void pointTo(Indexer indexer,
           String newIndex,
           String oldIndex)

pointTo

public void pointTo(Indexer indexer,
           String newIndex)

getCurrentActualTargetIndex

public String getCurrentActualTargetIndex(Indexer indexer)

getName

public String getName()