public interface ReplicationDao
Modifier and Type | Interface and Description |
---|---|
static class |
ReplicationDao.ReplicaDto
Data transfer object for replica queries.
|
Modifier and Type | Method and Description |
---|---|
List<org.dataone.service.types.v1.Identifier> |
getCompletedCoordinatingNodeReplicasByDate(Date auditDate,
int pageNumber,
int pageSize)
Returns paged list of distinct DataONE Identifier objects with at least
one coordinating node replica with a replica verified date previous to the auditDate
parameter.
|
List<org.dataone.service.types.v1.Identifier> |
getCompletedMemberNodeReplicasByDate(Date auditDate,
int pageNumber,
int pageSize)
Returns paged list of distinct DataONE Identifier objects with at least
one member node replica with a replica verified date previous to the auditDate
parameter.
|
Map<String,Integer> |
getCountsByNodeStatus()
Return a map of member node status to count entries for tracking node
replica status statistics.
|
List<org.dataone.service.types.v1.Identifier> |
getInvalidMemberNodeReplicasByDate(Date auditDate,
int pageNumber,
int pageSize)
Returns a paged list of distinct DataONE Identifier objects with at least one
invalid member node replica with a replica verified date previous to the
auditDate parameter.
|
Collection<org.dataone.service.types.v1.NodeReference> |
getMemberNodesWithQueuedReplica()
Returns a Collection of NodeReference objects which have at least one
queued replica object's targeted toward the node.
|
Map<org.dataone.service.types.v1.NodeReference,Integer> |
getPendingReplicasByNode()
Return a map of member node to replica count entries where the replica
status is either queued or requested
|
int |
getQueuedReplicaCountByNode(String nodeId)
Returns the count of replicas in the 'queued' status that are targeted
toward nodeId node.
|
Collection<ReplicationDao.ReplicaDto> |
getQueuedReplicasByNode(String nodeId)
Returns a Collection of ReplicaDto objects that represent a replica
object in 'queued' status and targeted at mnId node.
|
Map<org.dataone.service.types.v1.NodeReference,Integer> |
getRecentCompletedReplicas()
Return a map of member node to replica count entries where the replica
status is completed and the date_verified is within a given timeframe
|
Map<org.dataone.service.types.v1.NodeReference,Integer> |
getRecentFailedReplicas()
Return a map of member node to replica count entries where the replica
status is failed and the date_verified is within a given timeframe
|
List<ReplicationDao.ReplicaDto> |
getRequestedReplicasByDate(Date cutoffDate)
Returns a List of ReplicaDto objects, which represent replica objects
that are in 'Requested' status and have a verified date before
cuttoffDate.
|
int |
getRequestedReplicationCount(org.dataone.service.types.v1.NodeReference nodeReference)
Returns the count of replica objects in 'requested' status and targeted
to nodeReference node.
|
boolean |
queuedReplicaExists(String identifier,
String nodeId)
Returns true if there is a replica object with 'queued' status for
identifier targeted at nodeId.
|
List<org.dataone.service.types.v1.Identifier> getCompletedMemberNodeReplicasByDate(Date auditDate, int pageNumber, int pageSize) throws DataAccessException
auditDate
- - Identifiers with one or more replica verified dates after
audit date are returned.pageSize
- pageNumber
- DataAccessException
List<org.dataone.service.types.v1.Identifier> getCompletedCoordinatingNodeReplicasByDate(Date auditDate, int pageNumber, int pageSize) throws DataAccessException
auditDate
- - Identifiers with one or more replica verified dates after
audit date are returned.pageSize
- pageNumber
- DataAccessException
List<org.dataone.service.types.v1.Identifier> getInvalidMemberNodeReplicasByDate(Date auditDate, int pageNumber, int pageSize) throws DataAccessException
auditDate
- pageNumber
- pageSize
- DataAccessException
Map<org.dataone.service.types.v1.NodeReference,Integer> getPendingReplicasByNode() throws DataAccessException
DataAccessException
Map<org.dataone.service.types.v1.NodeReference,Integer> getRecentFailedReplicas() throws DataAccessException
DataAccessException
Map<org.dataone.service.types.v1.NodeReference,Integer> getRecentCompletedReplicas() throws DataAccessException
DataAccessException
Map<String,Integer> getCountsByNodeStatus() throws DataAccessException
DataAccessException
List<ReplicationDao.ReplicaDto> getRequestedReplicasByDate(Date cutoffDate) throws DataAccessException
cutoffDate
- DataAccessException
int getRequestedReplicationCount(org.dataone.service.types.v1.NodeReference nodeReference) throws DataAccessException
nodeReference
- DataAccessException
Collection<org.dataone.service.types.v1.NodeReference> getMemberNodesWithQueuedReplica() throws DataAccessException
DataAccessException
int getQueuedReplicaCountByNode(String nodeId) throws DataAccessException
nodeId
- DataAccessException
Collection<ReplicationDao.ReplicaDto> getQueuedReplicasByNode(String nodeId) throws DataAccessException
nodeId
- DataAccessException
boolean queuedReplicaExists(String identifier, String nodeId) throws DataAccessException
identifier
- nodeId
- DataAccessException
Copyright © 2020. All rights reserved.