public class MemberNodeReplicationAuditor extends AbstractReplicationAuditor
replicationDao| Constructor and Description |
|---|
MemberNodeReplicationAuditor() |
| Modifier and Type | Method and Description |
|---|---|
protected Date |
calculateAuditDate() |
protected long |
getFutureExecutionWaitTimeSeconds() |
protected String |
getLockName() |
protected int |
getMaxPages() |
protected int |
getPageSize() |
protected int |
getPidsPerTaskSize() |
protected List<org.dataone.service.types.v1.Identifier> |
getPidsToAudit(Date auditDate,
int pageNumber,
int pageSize) |
protected int |
getTaskPoolSize() |
protected Callable<String> |
newAuditTask(List<org.dataone.service.types.v1.Identifier> pids,
Date auditDate) |
protected boolean |
shouldRunAudit() |
auditReplication, getProcessingLock, releaseLock, run, tryLockprotected String getLockName()
getLockName in class AbstractReplicationAuditorprotected Date calculateAuditDate()
calculateAuditDate in class AbstractReplicationAuditorprotected List<org.dataone.service.types.v1.Identifier> getPidsToAudit(Date auditDate, int pageNumber, int pageSize) throws org.dataone.cn.dao.exceptions.DataAccessException
getPidsToAudit in class AbstractReplicationAuditororg.dataone.cn.dao.exceptions.DataAccessExceptionprotected Callable<String> newAuditTask(List<org.dataone.service.types.v1.Identifier> pids, Date auditDate)
newAuditTask in class AbstractReplicationAuditorprotected int getMaxPages()
getMaxPages in class AbstractReplicationAuditorprotected int getTaskPoolSize()
getTaskPoolSize in class AbstractReplicationAuditorprotected int getPageSize()
getPageSize in class AbstractReplicationAuditorprotected int getPidsPerTaskSize()
getPidsPerTaskSize in class AbstractReplicationAuditorprotected boolean shouldRunAudit()
shouldRunAudit in class AbstractReplicationAuditorprotected long getFutureExecutionWaitTimeSeconds()
getFutureExecutionWaitTimeSeconds in class AbstractReplicationAuditorCopyright © 2018. All rights reserved.