org.graylog2.periodical

Class IndexRotationThread

java.lang.Object

org.graylog2.plugin.periodical.Periodical

org.graylog2.periodical.IndexRotationThread

All Implemented Interfaces:

Runnable

public class IndexRotationThread
extends Periodical

Constructor Summary

Constructors

Constructor and Description
IndexRotationThread(NotificationService notificationService, Indices indices, IndexSetRegistry indexSetRegistry, Cluster cluster, ActivityWriter activityWriter, NodeId nodeId, Map<String,javax.inject.Provider<RotationStrategy>> rotationStrategyMap)

Method Summary

Modifier and Type	Method and Description
protected void	checkAndRepair(IndexSet indexSet)
protected void	checkForRotation(IndexSet indexSet)
void	doRun()
int	getInitialDelaySeconds()
protected org.slf4j.Logger	getLogger()
int	getPeriodSeconds()
boolean	isDaemon() Should this periodical be run as a daemon thread?
boolean	leaderOnly() Determines if this periodical should run only on the leader node.
boolean	runsForever() Defines if this thread should be called periodically or only once on startup.
boolean	startOnThisNode() Start on this node? Useful to decide if to start the periodical based on local configuration.
boolean	stopOnGracefulShutdown() Should this thread be stopped when a graceful shutdown is in progress? This means that stop() is called and that is no longer triggered periodically.

Methods inherited from class org.graylog2.plugin.periodical.Periodical

getParallelism, initialize, masterOnly, run

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexRotationThread

@Inject
public IndexRotationThread(NotificationService notificationService,
                                   Indices indices,
                                   IndexSetRegistry indexSetRegistry,
                                   Cluster cluster,
                                   ActivityWriter activityWriter,
                                   NodeId nodeId,
                                   Map<String,javax.inject.Provider<RotationStrategy>> rotationStrategyMap)

Method Detail

doRun

public void doRun()

Specified by:

doRun in class Periodical

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class Periodical

checkForRotation

protected void checkForRotation(IndexSet indexSet)

checkAndRepair

protected void checkAndRepair(IndexSet indexSet)

runsForever

public boolean runsForever()

Description copied from class: Periodical

Defines if this thread should be called periodically or only once on startup.

Specified by:

runsForever in class Periodical

Returns:

stopOnGracefulShutdown

public boolean stopOnGracefulShutdown()

Description copied from class: Periodical

Should this thread be stopped when a graceful shutdown is in progress? This means that stop() is called and that is no longer triggered periodically.

Specified by:

stopOnGracefulShutdown in class Periodical

Returns:

leaderOnly

public boolean leaderOnly()

Description copied from class: Periodical

Determines if this periodical should run only on the leader node.

Overrides:

leaderOnly in class Periodical

Returns:

false (default) if this periodical may run on every node. true if it may run only on the leader node

startOnThisNode

public boolean startOnThisNode()

Description copied from class: Periodical

Start on this node? Useful to decide if to start the periodical based on local configuration.

Specified by:

startOnThisNode in class Periodical

Returns:

isDaemon

public boolean isDaemon()

Description copied from class: Periodical

Should this periodical be run as a daemon thread?

Specified by:

isDaemon in class Periodical

Returns:

getInitialDelaySeconds

public int getInitialDelaySeconds()

Specified by:

getInitialDelaySeconds in class Periodical

Returns:

Seconds to wait before starting the thread. 0 for runsForever() threads.

getPeriodSeconds

public int getPeriodSeconds()

Specified by:

getPeriodSeconds in class Periodical

Returns:

How long to wait between each execution of the thread. 0 for runsForever() threads.