com.atlassian.jira.index.ha

Class DefaultReplicatedIndexManager

java.lang.Object

com.atlassian.jira.index.ha.DefaultReplicatedIndexManager

All Implemented Interfaces:

ReplicatedIndexManager

public class DefaultReplicatedIndexManager
extends Object
implements ReplicatedIndexManager

Manages the replicated index.

Since:

v6.1

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultReplicatedIndexManager.ReindexMetadataFilesProvider A contribution to the index backup, which writes metadata about the re-index

Constructor Summary

Constructors

Constructor and Description
DefaultReplicatedIndexManager(OfBizReplicatedIndexOperationStore ofBizReplicatedIndexOperationStore, TaskManager taskManager)

Method Summary

Modifier and Type	Method and Description
void	deIndexComment(WithIdAndVersion commentWithVersion)
void	deIndexIssue(WithIdAndVersion issueWithVersion) Removes the specified issues from the replicated index (we only need the ids for deindexing).
void	deIndexProject(Project project)
void	deIndexSharedEntity(SharedEntity entity) Deindexes the shared entity in the replicated index.
void	deIndexWorklog(WithIdAndVersion worklogWithVersion)
void	indexSharedEntity(SharedEntity entity) Reindexes the shared entity in the replicated index.
void	onReindexAllCompleted(ReindexAllCompletedEvent reindexAllCompletedEvent)
void	onReindexAllStarted(ReindexAllStartedEvent reindexAllStartedEvent)
void	reindexComments(Collection<? extends WithIdAndVersion> comments) Reindexes the set of provided comments in the replicated index.
void	reindexIssues(Collection<? extends WithIdAndVersion> issues) Reindexes the set of provided issues in the replicated index.
void	reindexProject(Project project) Notifies other nodes that they need to perform a project reindex.
void	reindexWorklogs(Collection<? extends WithIdAndVersion> worklogs) Reindexes the set of provided worklogs in the replicated index.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultReplicatedIndexManager

public DefaultReplicatedIndexManager(OfBizReplicatedIndexOperationStore ofBizReplicatedIndexOperationStore,
                                     TaskManager taskManager)

Method Detail

reindexIssues

public void reindexIssues(@Nonnull
                          Collection<? extends WithIdAndVersion> issues)

Reindexes the set of provided issues in the replicated index.

Specified by:

reindexIssues in interface ReplicatedIndexManager

Parameters:

issues - an Collection of issues to be reindexed

reindexComments

public void reindexComments(Collection<? extends WithIdAndVersion> comments)

Reindexes the set of provided comments in the replicated index.

Specified by:

reindexComments in interface ReplicatedIndexManager

Parameters:

comments - A collection of WithIdAndVersion representing comments to reindex

reindexWorklogs

public void reindexWorklogs(Collection<? extends WithIdAndVersion> worklogs)

Reindexes the set of provided worklogs in the replicated index.

Specified by:

reindexWorklogs in interface ReplicatedIndexManager

Parameters:

worklogs - A collection of WithIdAndVersion representing worklogs to reindex

deIndexIssue

public void deIndexIssue(WithIdAndVersion issueWithVersion)

Removes the specified issues from the replicated index (we only need the ids for deindexing).

Specified by:

deIndexIssue in interface ReplicatedIndexManager

Parameters:

issueWithVersion - WithIds for the Issues to mark as deleted.

deIndexComment

public void deIndexComment(WithIdAndVersion commentWithVersion)

Specified by:

deIndexComment in interface ReplicatedIndexManager

deIndexWorklog

public void deIndexWorklog(WithIdAndVersion worklogWithVersion)

Specified by:

deIndexWorklog in interface ReplicatedIndexManager

reindexProject

public void reindexProject(Project project)

Notifies other nodes that they need to perform a project reindex.

Unlike deIndexProject(com.atlassian.jira.project.Project), this method does not create an index snapshot. This is because it is called as soon as project reindex is commenced on this node, without waiting until it's finished. Index snapshot is created in ReIndexProjectIndexerCommand.call().

Specified by:

reindexProject in interface ReplicatedIndexManager

deIndexProject

public void deIndexProject(Project project)

Specified by:

deIndexProject in interface ReplicatedIndexManager

indexSharedEntity

public void indexSharedEntity(SharedEntity entity)

Reindexes the shared entity in the replicated index.

Specified by:

indexSharedEntity in interface ReplicatedIndexManager

Parameters:

entity - the SharedEntity to be reindexed

deIndexSharedEntity

public void deIndexSharedEntity(SharedEntity entity)

Deindexes the shared entity in the replicated index.

Specified by:

deIndexSharedEntity in interface ReplicatedIndexManager

Parameters:

entity - the SharedEntity to be removed

onReindexAllStarted

@EventListener
public void onReindexAllStarted(ReindexAllStartedEvent reindexAllStartedEvent)

onReindexAllCompleted

@EventListener
public void onReindexAllCompleted(ReindexAllCompletedEvent reindexAllCompletedEvent)