public class ReplicationResource extends Object
Modifier and Type | Field and Description |
---|---|
static int |
RIO_SIZE_WARNING_THRESHOLD |
Constructor and Description |
---|
ReplicationResource(ClusterManager clusterManager,
OfBizDelegator ofBizDelegator,
BuildUtilsInfo buildUtilsInfo) |
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.
|
public static final int RIO_SIZE_WARNING_THRESHOLD
public ReplicationResource(ClusterManager clusterManager, OfBizDelegator ofBizDelegator, BuildUtilsInfo buildUtilsInfo)
public javax.ws.rs.core.Response waitForAllReplicationOperations(long maxTimeToWaitMs)
maxTimeToWaitMs
- the maximum amount of time to wait in milliseconds. If nodes are not replicated
after this time an error is produced.public javax.ws.rs.core.Response waitForNodeReplicationOperations(long maxTimeToWaitMs)
maxTimeToWaitMs
- the maximum amount of time to wait in milliseconds. If nodes are not replicated
after this time an error is produced.public String waitForClusterNodes(int nodeCount, long maxTimeToWaitMs)
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.Copyright © 2002-2022 Atlassian. All Rights Reserved.