Package com.atlassian.jira.search.index.rio

Class ClusterSynchronisedIndexReplayStrategy

java.lang.Object

com.atlassian.jira.search.index.rio.ClusterSynchronisedIndexReplayStrategy

All Implemented Interfaces:

IndexReplayStrategy

public class ClusterSynchronisedIndexReplayStrategy
extends Object
implements IndexReplayStrategy

Orchestrates replaying the outstanding index operations to the search index.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ClusterSynchronisedIndexReplayStrategy.Transaction

Constructor Summary

Constructors

Constructor	Description
ClusterSynchronisedIndexReplayStrategy(ReplicatedIndexOperationCounterService rioCounterService, ReplicatedIndexOperationsService rioService, WritableIndexAccessor indexAccessor, OpenSearchIndexReplayStats statsLogger, com.atlassian.instrumentation.Counter totalOperationCountInstrument, ClusterSynchronisedIndexReplayStrategyFactory.LatestGaugeValue latestGaugeValue)

Method Summary

Modifier and Type	Method	Description
IndexReplayStrategy.Transaction	createTransaction()	Creates a transaction for replaying index operations.
ClusterSynchronisedIndexReplayStrategyFactory.LatestGaugeValue	getLatestGaugeValue()
com.atlassian.instrumentation.Counter	getTotalOperationCountInstrument()
void	replay()	Replays the outstanding index operations to the search index.

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterSynchronisedIndexReplayStrategy

public ClusterSynchronisedIndexReplayStrategy(ReplicatedIndexOperationCounterService rioCounterService,
 ReplicatedIndexOperationsService rioService,
 WritableIndexAccessor indexAccessor,
 OpenSearchIndexReplayStats statsLogger,
 com.atlassian.instrumentation.Counter totalOperationCountInstrument,
 ClusterSynchronisedIndexReplayStrategyFactory.LatestGaugeValue latestGaugeValue)

Method Details

replay

public void replay()
            throws SearchException,
IndexOperationException

Description copied from interface: IndexReplayStrategy

Replays the outstanding index operations to the search index. This method is responsible for fetching the unprocessed index operations, processing them, and updating the index operation counter accordingly.

Specified by:

replay in interface IndexReplayStrategy

Throws:

SearchException

IndexOperationException

createTransaction

public IndexReplayStrategy.Transaction createTransaction()

Description copied from interface: IndexReplayStrategy

Creates a transaction for replaying index operations. This allows finer control over the replay process, enabling replays to be written to an index without writing the counter to the database

Specified by:

createTransaction in interface IndexReplayStrategy

Returns:

a new transaction instance

getTotalOperationCountInstrument

public com.atlassian.instrumentation.Counter getTotalOperationCountInstrument()

getLatestGaugeValue

public ClusterSynchronisedIndexReplayStrategyFactory.LatestGaugeValue getLatestGaugeValue()