public class ReplicationTaskQueue extends Object
| Constructor and Description |
|---|
ReplicationTaskQueue() |
| Modifier and Type | Method and Description |
|---|---|
int |
getCountOfTasksForNode(String nodeId)
Returns the count of queued replica objects for the node specified by the
nodeId parameter.
|
Collection<org.dataone.service.types.v1.NodeReference> |
getMemberNodesInQueue()
Returns a Collection of NodeReference objects for member nodes that
currently have queued replicas.
|
void |
logState() |
void |
processAllTasksForMN(String memberNodeIdentifierValue)
Attempt to move each 'queued' replica to the 'requested' state for the
member node specified by the memberNodeIdentifierValue parameter.
|
public void logState()
public Collection<org.dataone.service.types.v1.NodeReference> getMemberNodesInQueue()
public int getCountOfTasksForNode(String nodeId)
nodeId - public void processAllTasksForMN(String memberNodeIdentifierValue)
memberNodeIdentifierValue - Copyright © 2018. All rights reserved.