Package com.atlassian.jira.search.opensearch

Class OpenSearchReplicatedIndexOperationConsistencyChecker

java.lang.Object

com.atlassian.jira.search.opensearch.OpenSearchReplicatedIndexOperationConsistencyChecker

All Implemented Interfaces:

ReplicatedIndexOperationConsistencyChecker

public class OpenSearchReplicatedIndexOperationConsistencyChecker
extends Object
implements ReplicatedIndexOperationConsistencyChecker

Constructor Summary

Constructors

Constructor	Description
OpenSearchReplicatedIndexOperationConsistencyChecker(org.opensearch.client.opensearch.OpenSearchClient openSearchClient, JiraProperties jiraProperties, io.github.resilience4j.retry.RetryRegistry retryRegistry)

Method Summary

Modifier and Type	Method	Description
List<EntityWithOperation>	getUnappliedOperations(Collection<EntityWithOperation> operations, IndexAccessor indexAccessor)	Checks for RIO operations which have not been applied to the index yet.

Methods inherited from class java.lang.Object

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

Constructor Details

OpenSearchReplicatedIndexOperationConsistencyChecker

public OpenSearchReplicatedIndexOperationConsistencyChecker(org.opensearch.client.opensearch.OpenSearchClient openSearchClient,
 JiraProperties jiraProperties,
 io.github.resilience4j.retry.RetryRegistry retryRegistry)

Method Details

getUnappliedOperations

public List<EntityWithOperation> getUnappliedOperations(Collection<EntityWithOperation> operations,
 IndexAccessor indexAccessor)
                                                 throws OpenSearchSearchException

Description copied from interface: ReplicatedIndexOperationConsistencyChecker

Checks for RIO operations which have not been applied to the index yet.

Specified by:

getUnappliedOperations in interface ReplicatedIndexOperationConsistencyChecker

Parameters:

operations - the list of operations to check

indexAccessor - the index accessor to use for checking the index

Returns:

a list of operations that are missing from the index

Throws:

OpenSearchSearchException