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.