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, tryLock
protected String getLockName()
getLockName
in class AbstractReplicationAuditor
protected Date calculateAuditDate()
calculateAuditDate
in class AbstractReplicationAuditor
protected List<org.dataone.service.types.v1.Identifier> getPidsToAudit(Date auditDate, int pageNumber, int pageSize) throws org.dataone.cn.dao.exceptions.DataAccessException
getPidsToAudit
in class AbstractReplicationAuditor
org.dataone.cn.dao.exceptions.DataAccessException
protected Callable<String> newAuditTask(List<org.dataone.service.types.v1.Identifier> pids, Date auditDate)
newAuditTask
in class AbstractReplicationAuditor
protected int getMaxPages()
getMaxPages
in class AbstractReplicationAuditor
protected int getTaskPoolSize()
getTaskPoolSize
in class AbstractReplicationAuditor
protected int getPageSize()
getPageSize
in class AbstractReplicationAuditor
protected int getPidsPerTaskSize()
getPidsPerTaskSize
in class AbstractReplicationAuditor
protected boolean shouldRunAudit()
shouldRunAudit
in class AbstractReplicationAuditor
protected long getFutureExecutionWaitTimeSeconds()
getFutureExecutionWaitTimeSeconds
in class AbstractReplicationAuditor
Copyright © 2018. All rights reserved.