public class ReplicationDaoMetacatImpl extends Object implements ReplicationDao
ReplicationDao.ReplicaDto
Constructor and Description |
---|
ReplicationDaoMetacatImpl() |
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()
Get a map of replica counts by node-status in order to support
instrumentation of system wide MN to MN replication functionality.
|
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()
Retrieve the count of pending replica requests per target node listed in
the Coordinating Node's smreplicationstatus table.
|
int |
getQueuedReplicaCountByNode(String nodeId)
Returns the count of replicas in the 'queued' status that are targeted
toward nodeId node.
|
Collection<ReplicationDao.ReplicaDto> |
getQueuedReplicasByNode(String mnId)
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()
Retrieve the count of recently completed replica requests per target node
listed in the Coordinating Node's systemetadatareplicationstatus table.
|
Map<org.dataone.service.types.v1.NodeReference,Integer> |
getRecentFailedReplicas()
Retrieve the count of recently failed replica requests per target node
listed in the Coordinating Node's systemetadatareplicationstatus table.
|
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 nodeRef)
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.
|
public Collection<org.dataone.service.types.v1.NodeReference> getMemberNodesWithQueuedReplica() throws DataAccessException
ReplicationDao
getMemberNodesWithQueuedReplica
in interface ReplicationDao
DataAccessException
public int getQueuedReplicaCountByNode(String nodeId) throws DataAccessException
ReplicationDao
getQueuedReplicaCountByNode
in interface ReplicationDao
DataAccessException
public Collection<ReplicationDao.ReplicaDto> getQueuedReplicasByNode(String mnId) throws DataAccessException
ReplicationDao
getQueuedReplicasByNode
in interface ReplicationDao
DataAccessException
public boolean queuedReplicaExists(String identifier, String nodeId) throws DataAccessException
ReplicationDao
queuedReplicaExists
in interface ReplicationDao
DataAccessException
public List<org.dataone.service.types.v1.Identifier> getInvalidMemberNodeReplicasByDate(Date auditDate, int pageNumber, int pageSize) throws DataAccessException
ReplicationDao
getInvalidMemberNodeReplicasByDate
in interface ReplicationDao
DataAccessException
public List<org.dataone.service.types.v1.Identifier> getCompletedMemberNodeReplicasByDate(Date auditDate, int pageNumber, int pageSize) throws DataAccessException
ReplicationDao
getCompletedMemberNodeReplicasByDate
in interface ReplicationDao
auditDate
- - Identifiers with one or more replica verified dates after
audit date are returned.DataAccessException
public List<org.dataone.service.types.v1.Identifier> getCompletedCoordinatingNodeReplicasByDate(Date auditDate, int pageNumber, int pageSize) throws DataAccessException
ReplicationDao
getCompletedCoordinatingNodeReplicasByDate
in interface ReplicationDao
auditDate
- - Identifiers with one or more replica verified dates after
audit date are returned.DataAccessException
public List<ReplicationDao.ReplicaDto> getRequestedReplicasByDate(Date cutoffDate) throws DataAccessException
ReplicationDao
getRequestedReplicasByDate
in interface ReplicationDao
DataAccessException
public int getRequestedReplicationCount(org.dataone.service.types.v1.NodeReference nodeRef) throws DataAccessException
ReplicationDao
getRequestedReplicationCount
in interface ReplicationDao
DataAccessException
public Map<org.dataone.service.types.v1.NodeReference,Integer> getPendingReplicasByNode() throws DataAccessException
getPendingReplicasByNode
in interface ReplicationDao
DataAccessException
public Map<org.dataone.service.types.v1.NodeReference,Integer> getRecentFailedReplicas() throws DataAccessException
getRecentFailedReplicas
in interface ReplicationDao
DataAccessException
public Map<org.dataone.service.types.v1.NodeReference,Integer> getRecentCompletedReplicas() throws DataAccessException
getRecentCompletedReplicas
in interface ReplicationDao
DataAccessException
public Map<String,Integer> getCountsByNodeStatus() throws DataAccessException
getCountsByNodeStatus
in interface ReplicationDao
DataAccessException
Copyright © 2020. All rights reserved.