| Package | Description |
|---|---|
| org.dataone.cn.batch.service.v2.impl | |
| org.dataone.cn.batch.synchronization.tasks | |
| org.dataone.cn.batch.synchronization.type |
| Modifier and Type | Class and Description |
|---|---|
class |
NodeRegistrySyncServiceImpl |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ObjectListHarvestTask.spoolToSynchronizationQueue(SortedHarvestTimepointMap harvest,
SyncQueueFacade hzSyncObjectQueue,
NodeRegistrySyncService nodeRegistryService,
Integer requeueTolerance)
Submit the harvest to the sync queue, periodically updating the node's lastHarvestedDate
(able to do this since the pids are already sorted)
|
| Modifier and Type | Method and Description |
|---|---|
NodeRegistrySyncService |
NodeComm.getNodeRegistryService() |
| Modifier and Type | Method and Description |
|---|---|
void |
NodeComm.setNodeRegistryService(NodeRegistrySyncService nodeRegistryService) |
| Constructor and Description |
|---|
NodeComm(Object mnRead,
NodeRegistrySyncService nodeRegistryService) |
NodeComm(Object mnRead,
Object cnRead,
NodeRegistrySyncService nodeRegistryService,
org.dataone.service.cn.v2.CNCore cnCore,
org.dataone.service.cn.v2.CNReplication cnReplication,
IdentifierReservationQueryService reserveIdentifierService) |
Copyright © 2021. All rights reserved.