Package com.atlassian.jira.index.ha

Class OpenSearchReplicatedIndexManager

java.lang.Object

com.atlassian.jira.index.ha.DefaultReplicatedIndexManager

com.atlassian.jira.index.ha.OpenSearchReplicatedIndexManager

All Implemented Interfaces:

ReplicatedIndexManager

public class OpenSearchReplicatedIndexManager
extends DefaultReplicatedIndexManager

Implementation for the DefaultReplicatedIndexManager to be used when OpenSearch is running.

When OpenSearch is used, the only index left on Lucene is for shared entities, and therefore all other index and deindex methods from DefaultReplicatedIndexManager have an override to do nothing.

When the reindex end event is triggered, this adds the message to the RIO table to tell the other nodes in the cluster to reindex their shared entities.

Nested Class Summary

Nested classes/interfaces inherited from class com.atlassian.jira.index.ha.DefaultReplicatedIndexManager

DefaultReplicatedIndexManager.ReindexMetadataFilesProvider

Constructor Summary

Constructors

Constructor	Description
OpenSearchReplicatedIndexManager(OfBizReplicatedIndexOperationStore ofBizReplicatedIndexOperationStore, TaskManager taskManager)

Method Summary

Modifier and Type	Method	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	deIndexWorklog(WithIdAndVersion worklogWithVersion)
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 com.atlassian.jira.index.ha.DefaultReplicatedIndexManager

deIndexSharedEntity, getOfBizReplicatedIndexOperationStore, indexSharedEntity

Methods inherited from class java.lang.Object

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

Constructor Details

OpenSearchReplicatedIndexManager

public OpenSearchReplicatedIndexManager(OfBizReplicatedIndexOperationStore ofBizReplicatedIndexOperationStore,
 TaskManager taskManager)

Method Details

onReindexAllStarted

@EventListener
public void onReindexAllStarted(ReindexAllStartedEvent reindexAllStartedEvent)

Overrides:

onReindexAllStarted in class DefaultReplicatedIndexManager

onReindexAllCompleted

@EventListener
public void onReindexAllCompleted(ReindexAllCompletedEvent reindexAllCompletedEvent)

Overrides:

onReindexAllCompleted in class DefaultReplicatedIndexManager

reindexIssues

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

Description copied from class: DefaultReplicatedIndexManager

Reindexes the set of provided issues in the replicated index.

Specified by:

reindexIssues in interface ReplicatedIndexManager

Overrides:

reindexIssues in class DefaultReplicatedIndexManager

Parameters:

issues - an Collection of issues to be reindexed

reindexComments

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

Description copied from class: DefaultReplicatedIndexManager

Reindexes the set of provided comments in the replicated index.

Specified by:

reindexComments in interface ReplicatedIndexManager

Overrides:

reindexComments in class DefaultReplicatedIndexManager

Parameters:

comments - A collection of WithIdAndVersion representing comments to reindex

reindexWorklogs

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

Description copied from class: DefaultReplicatedIndexManager

Reindexes the set of provided worklogs in the replicated index.

Specified by:

reindexWorklogs in interface ReplicatedIndexManager

Overrides:

reindexWorklogs in class DefaultReplicatedIndexManager

Parameters:

worklogs - A collection of WithIdAndVersion representing worklogs to reindex

deIndexIssue

public void deIndexIssue(WithIdAndVersion issueWithVersion)

Description copied from class: DefaultReplicatedIndexManager

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

Specified by:

deIndexIssue in interface ReplicatedIndexManager

Overrides:

deIndexIssue in class DefaultReplicatedIndexManager

Parameters:

issueWithVersion - WithIds for the Issues to mark as deleted.

deIndexComment

public void deIndexComment(WithIdAndVersion commentWithVersion)

Specified by:

deIndexComment in interface ReplicatedIndexManager

Overrides:

deIndexComment in class DefaultReplicatedIndexManager

deIndexWorklog

public void deIndexWorklog(WithIdAndVersion worklogWithVersion)

Specified by:

deIndexWorklog in interface ReplicatedIndexManager

Overrides:

deIndexWorklog in class DefaultReplicatedIndexManager

reindexProject

public void reindexProject(Project project)

Description copied from class: DefaultReplicatedIndexManager

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

Unlike DefaultReplicatedIndexManager.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 Callable.call().

Specified by:

reindexProject in interface ReplicatedIndexManager

Overrides:

reindexProject in class DefaultReplicatedIndexManager

deIndexProject

public void deIndexProject(Project project)

Specified by:

deIndexProject in interface ReplicatedIndexManager

Overrides:

deIndexProject in class DefaultReplicatedIndexManager