com.atlassian.jira.plugins.ha.rest

Class ReplicationResource

java.lang.Object

com.atlassian.jira.plugins.ha.rest.ReplicationResource

public class ReplicationResource
extends Object

The web resource for replication management.

Since:

6.3

Field Summary

Fields

Modifier and Type	Field and Description
static int	RIO_SIZE_WARNING_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
ReplicationResource(ClusterManager clusterManager, OfBizDelegator ofBizDelegator, BuildUtilsInfo buildUtilsInfo)

Method Summary

Modifier and Type	Method and Description
javax.ws.rs.core.Response	waitForAllReplicationOperations(long maxTimeToWaitMs) Waits for all replication operations between nodes in the cluster to complete.
String	waitForClusterNodes(int nodeCount, long maxTimeToWaitMs) Waits until the specified number of nodes become active in the cluster.
javax.ws.rs.core.Response	waitForNodeReplicationOperations(long maxTimeToWaitMs) Waits for a current node to consume all indexing operations in cluster.

Methods inherited from class java.lang.Object

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

Field Detail

RIO_SIZE_WARNING_THRESHOLD

public static final int RIO_SIZE_WARNING_THRESHOLD

See Also:

Constant Field Values

Constructor Detail

ReplicationResource

public ReplicationResource(ClusterManager clusterManager,
                           OfBizDelegator ofBizDelegator,
                           BuildUtilsInfo buildUtilsInfo)

Method Detail

waitForAllReplicationOperations

public javax.ws.rs.core.Response waitForAllReplicationOperations(long maxTimeToWaitMs)

Waits for all replication operations between nodes in the cluster to complete. This method assumes that operations triggering indexing have been completed (RIO table is not changing any more) and we are waiting for the cluster to arrive at an everything-is-synced state.

Parameters:

maxTimeToWaitMs - the maximum amount of time to wait in milliseconds. If nodes are not replicated after this time an error is produced.

Returns:

the actual amount of time waited.

waitForNodeReplicationOperations

public javax.ws.rs.core.Response waitForNodeReplicationOperations(long maxTimeToWaitMs)

Waits for a current node to consume all indexing operations in cluster. This method assumes that operations triggering indexing have been completed (RIO table is not changing any more) and we are waiting for the cluster to arrive at an everything-is-synced state.

Parameters:

maxTimeToWaitMs - the maximum amount of time to wait in milliseconds. If nodes are not replicated after this time an error is produced.

Returns:

the actual amount of time waited.

waitForClusterNodes

public String waitForClusterNodes(int nodeCount,
                                  long maxTimeToWaitMs)

Waits until the specified number of nodes become active in the cluster.

Parameters:

nodeCount - the number of nodes the cluster must have.

maxTimeToWaitMs - the maximum amount of time to wait in milliseconds. An error is returned if the required number of nodes are not active after this time.

Returns:

the amount of time waited.