com.atlassian.jira.index.ha

Class OfBizReplicatedIndexOperationStore

java.lang.Object

com.atlassian.jira.index.ha.OfBizReplicatedIndexOperationStore

public class OfBizReplicatedIndexOperationStore
extends Object

Stores index operation events

Since:

v6.1

Constructor Summary

Constructors

Constructor and Description
OfBizReplicatedIndexOperationStore(OfBizDelegator ofBizDelegator, QueryDslAccessor queryDslAccessor)

Method Summary

Modifier and Type	Method and Description
boolean	contains(long id)
Long	createIndexOperation(AffectedIndex affectedIndex, SharedEntityType entityType, ReplicatedIndexOperation.Operation operation, Map<Long,Long> affectedIdToVersion, String backupFilename) Creates and stores the index operation in the underlying database, only if the node is in a cluster.
Long	createIndexOperationForNonVersionEntities(AffectedIndex affectedIndex, SharedEntityType entityType, ReplicatedIndexOperation.Operation operation, Collection<Long> affectedIds, String backupFilename) Creates and stores the index operation in the underlying database, only if the node is in a cluster.
Set<ReplicatedIndexOperation>	getIndexOperationsAfter(String sourceNodeId, Long operationId) Returns a set of IndexOperations that have happened after the given operationId.
Set<ReplicatedIndexOperation>	getIndexOperationsAfterIdAndOlderThan(String sourceNodeId, Long operationId, int ageThresholdInSec) Returns a set of IndexOperations that have happened after the given operationId and are older then given ageThresholdInSec (i.e.
Long	getLatestOperation(String sourceNodeId) Returns The latest operation for this node
ReplicatedIndexOperation	getOperation(long id) get an operation by id
int	purgeOldOperations(String sourceNodeId, Date before)

Methods inherited from class java.lang.Object

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

Constructor Detail

OfBizReplicatedIndexOperationStore

public OfBizReplicatedIndexOperationStore(OfBizDelegator ofBizDelegator,
                                          QueryDslAccessor queryDslAccessor)

Method Detail

createIndexOperation

@Nullable
public Long createIndexOperation(AffectedIndex affectedIndex,
                                           SharedEntityType entityType,
                                           ReplicatedIndexOperation.Operation operation,
                                           Map<Long,Long> affectedIdToVersion,
                                           String backupFilename)

Creates and stores the index operation in the underlying database, only if the node is in a cluster.

Parameters:

operation - the ReplicatedIndexOperation.Operation that was performed on the underlying index

affectedIdToVersion - Map of affectedId to local version that participated in the index operation

Returns:

the operation id that was inserted into the underlying db - may be null if the node is not clustered

createIndexOperationForNonVersionEntities

@Nullable
public Long createIndexOperationForNonVersionEntities(AffectedIndex affectedIndex,
                                                                SharedEntityType entityType,
                                                                ReplicatedIndexOperation.Operation operation,
                                                                Collection<Long> affectedIds,
                                                                String backupFilename)

Creates and stores the index operation in the underlying database, only if the node is in a cluster.

Parameters:

operation - the ReplicatedIndexOperation.Operation that was performed on the underlying index

affectedIds - list of affectedIds that participated in the index operation

Returns:

the operation id that was inserted into the underlying db - may be null if the node is not clustered

purgeOldOperations

public int purgeOldOperations(String sourceNodeId,
                              Date before)

getIndexOperationsAfter

public Set<ReplicatedIndexOperation> getIndexOperationsAfter(String sourceNodeId,
                                                             Long operationId)

Returns a set of IndexOperations that have happened after the given operationId. We do this by node as the ids are not monotonically increasing across nodes.

Parameters:

sourceNodeId - Node to get operations sent from

operationId - identifier for the Operation to get the operations after (exclusively)

Returns:

a set of ReplicatedIndexOperation that have taken place on other nodes after a specified id

getIndexOperationsAfterIdAndOlderThan

public Set<ReplicatedIndexOperation> getIndexOperationsAfterIdAndOlderThan(String sourceNodeId,
                                                                           Long operationId,
                                                                           int ageThresholdInSec)

Returns a set of IndexOperations that have happened after the given operationId and are older then given ageThresholdInSec (i.e. ReplicatedIndexOperation.indexTime is < DB.now() - ageThresholdInSec). We do this by node as the ids are not monotonically increasing across nodes.

Parameters:

sourceNodeId - Node to get operations sent from

operationId - identifier for the Operation to get the operations after (exclusively)

ageThresholdInSec - threshold to get the operations which is older than

Returns:

a set of ReplicatedIndexOperation that have taken place on other nodes after a specified id

getOperation

public ReplicatedIndexOperation getOperation(long id)

get an operation by id

Returns:

the operation.

getLatestOperation

public Long getLatestOperation(String sourceNodeId)

Returns The latest operation for this node

Parameters:

sourceNodeId - source node of the operation

Returns:

id of the latest operation.

contains

public boolean contains(long id)

Parameters:

id - the NodeIndexOperation id to check

Returns:

true if the database contains this index operation