Package com.atlassian.jira.index.ha

Class DefaultServerIndexRepairService

java.lang.Object

com.atlassian.jira.index.ha.DefaultServerIndexRepairService

All Implemented Interfaces:

SingleNodeIndexRepairService

public class DefaultServerIndexRepairService
extends Object
implements SingleNodeIndexRepairService

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_MAX_TIMESPAN_SECONDS
static final long	DEFAULT_PERIOD_SECONDS
static final long	DEFAULT_SAFETY_MARGIN_SECONDS	See SYSTEM_PROPERTY_SAFETY_MARGIN_SECONDS for an explanation of these two constituents of the safety margin.
static final String	SYSTEM_PROPERTY_MAX_TIMESPAN_SECONDS
static final String	SYSTEM_PROPERTY_PERIOD_SECONDS
static final String	SYSTEM_PROPERTY_SAFETY_MARGIN_SECONDS	The repair job replays all de-index operations since the lastRun.

Constructor Summary

Constructors

Constructor	Description
DefaultServerIndexRepairService(JiraProperties jiraProperties, com.atlassian.event.api.EventPublisher eventPublisher, IndexRecoveryManager indexRecoveryManager)

Method Summary

Modifier and Type	Method	Description
void	onImportCompletedEvent(ImportCompletedEvent event)
void	onImportStartedEvent(ImportStartedEvent event)
void	onIndexingShutdownEvent(IndexingShutdownEvent event)
void	onPluginFrameworkShutdown(com.atlassian.plugin.event.events.PluginFrameworkShutdownEvent event)
void	onPluginFrameworkStarted(com.atlassian.plugin.event.events.PluginFrameworkStartedEvent event)
void	pause()
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Field Details

SYSTEM_PROPERTY_PERIOD_SECONDS

public static final String SYSTEM_PROPERTY_PERIOD_SECONDS

See Also:

• Constant Field Values

DEFAULT_PERIOD_SECONDS

public static final long DEFAULT_PERIOD_SECONDS

See Also:

• Constant Field Values

SYSTEM_PROPERTY_MAX_TIMESPAN_SECONDS

public static final String SYSTEM_PROPERTY_MAX_TIMESPAN_SECONDS

See Also:

• Constant Field Values

DEFAULT_MAX_TIMESPAN_SECONDS

public static final long DEFAULT_MAX_TIMESPAN_SECONDS

SYSTEM_PROPERTY_SAFETY_MARGIN_SECONDS

public static final String SYSTEM_PROPERTY_SAFETY_MARGIN_SECONDS

The repair job replays all de-index operations since the lastRun. However, we need to take into account possible delays. A (relatively small) delay can happen between when we calculate the range in deindexRecentOperations() and when we actually execute IndexRecoveryManager.deindexEntitiesDeletedInTheLast(Duration, TaskProgressSink). The safety margin needs to be long enough for the next repair job to "reach" the deletion operation of the slowly indexed issue. Therefore, the second constituent of the safety margin needs to be as long as we allow the issue document building to be. The corresponding mechanism in DC is based on DefaultNodeReindexService replaying local node operations after a fixed delay. The delay is configured in DefaultNodeReindexService#delayInSeconds and is tied to LocalQConfig.putTTLMillis().

See Also:

• Constant Field Values

DEFAULT_SAFETY_MARGIN_SECONDS

public static final long DEFAULT_SAFETY_MARGIN_SECONDS

See SYSTEM_PROPERTY_SAFETY_MARGIN_SECONDS for an explanation of these two constituents of the safety margin.

See Also:

• Constant Field Values

Constructor Details

DefaultServerIndexRepairService

public DefaultServerIndexRepairService(JiraProperties jiraProperties,
 com.atlassian.event.api.EventPublisher eventPublisher,
 IndexRecoveryManager indexRecoveryManager)

Method Details

onPluginFrameworkStarted

@EventListener
public void onPluginFrameworkStarted(com.atlassian.plugin.event.events.PluginFrameworkStartedEvent event)

Specified by:

onPluginFrameworkStarted in interface SingleNodeIndexRepairService

onIndexingShutdownEvent

@EventListener
public void onIndexingShutdownEvent(IndexingShutdownEvent event)

Specified by:

onIndexingShutdownEvent in interface SingleNodeIndexRepairService

onImportStartedEvent

@EventListener
public void onImportStartedEvent(ImportStartedEvent event)

Specified by:

onImportStartedEvent in interface SingleNodeIndexRepairService

onImportCompletedEvent

@EventListener
public void onImportCompletedEvent(ImportCompletedEvent event)

Specified by:

onImportCompletedEvent in interface SingleNodeIndexRepairService

pause

public void pause()

Specified by:

pause in interface SingleNodeIndexRepairService

start

public void start()

Specified by:

start in interface SingleNodeIndexRepairService

onPluginFrameworkShutdown

@EventListener
public void onPluginFrameworkShutdown(com.atlassian.plugin.event.events.PluginFrameworkShutdownEvent event)

Specified by:

onPluginFrameworkShutdown in interface SingleNodeIndexRepairService

shutdown

public void shutdown()

Specified by:

shutdown in interface SingleNodeIndexRepairService