Skip navigation links
A C D E F G I L M O P Q R S T U V 

A

ApiVersion - Class in org.dataone.service.cn.replication
 

C

calcQualifiedReplicas(SystemMetadata) - Method in class org.dataone.service.cn.replication.ReplicationManager
Given the current system metadata object, return a list of already listed replica entries that are in the queued, requested, or completed state.
call() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Implement the Callable interface, providing code that initiates replication.
closeContext() - Method in interface org.dataone.service.cn.replication.ReplicationRepositoryFactory
 
compareTo(ApiVersion) - Method in class org.dataone.service.cn.replication.ApiVersion
 
createAndQueueTasks(Identifier) - Method in class org.dataone.service.cn.replication.ReplicationManager
Create replication tasks given the identifier of an object by evaluating its system metadata and the capabilities of the target replication nodes.

D

dataSource() - Method in class org.dataone.cn.data.repository.ReplicationPostgresRepositoryFactory
 
deleteReplicationMetadata(Identifier, NodeReference) - Method in class org.dataone.service.cn.replication.ReplicationService
Delete the replica entry for the target node using the CN router URL rather than the local CN via D1Client.
determineReplicationSourceNode(SystemMetadata) - Method in class org.dataone.service.cn.replication.ReplicationService
 

E

entryAdded(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.service.cn.replication.ReplicationEventListener
Implement the EntryListener interface, responding to entries being added to the hzSystemMetadata map.
entryEvicted(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.service.cn.replication.ReplicationEventListener
Implement the EntryListener interface, responding to entries being evicted from the hzSystemMetadata map.
entryRemoved(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.service.cn.replication.ReplicationEventListener
Implement the EntryListener interface, responding to entries being deleted from the hzSystemMetadata map.
entryUpdated(EntryEvent<Identifier, SystemMetadata>) - Method in class org.dataone.service.cn.replication.ReplicationEventListener
Implement the EntryListener interface, responding to entries being updated in the hzSystemMetadata map.

F

findByNodeId(String) - Method in interface org.dataone.cn.data.repository.ReplicationAttemptHistoryRepository
 
findByPid(String) - Method in interface org.dataone.cn.data.repository.ReplicationAttemptHistoryRepository
 
findByPid(String, Pageable) - Method in interface org.dataone.cn.data.repository.ReplicationAttemptHistoryRepository
 
findByPid(String) - Method in interface org.dataone.cn.data.repository.ReplicationTaskRepository
 
findByPidAndNodeId(String, String) - Method in interface org.dataone.cn.data.repository.ReplicationAttemptHistoryRepository
 
findByReplicationAttempts(Integer) - Method in interface org.dataone.cn.data.repository.ReplicationAttemptHistoryRepository
 
findByStatusAndNextExecutionLessThan(String, long) - Method in interface org.dataone.cn.data.repository.ReplicationTaskRepository
 
findByStatusAndNextExecutionLessThanOrderByNextExecutionAsc(String, long, Pageable) - Method in interface org.dataone.cn.data.repository.ReplicationTaskRepository
 

G

getApiLabel() - Method in class org.dataone.service.cn.replication.ApiVersion
 
getApiValue() - Method in class org.dataone.service.cn.replication.ApiVersion
 
getBandwidthFactors(List<NodeReference>, boolean) - Method in class org.dataone.service.cn.replication.ReplicationPrioritizationStrategy
For the given nodes, return the bandwidth factor as a surrogate for the nodes' demonstrated throughput over a recent time period.
getChecksumFromMN(Identifier, NodeReference, SystemMetadata) - Method in class org.dataone.service.cn.replication.ReplicationCommunication
 
getChecksumFromMN(Identifier, NodeReference, SystemMetadata) - Method in class org.dataone.service.cn.replication.v1.MNCommunication
 
getChecksumFromMN(Identifier, NodeReference, SystemMetadata) - Method in class org.dataone.service.cn.replication.v2.MNCommunication
 
getCountOfTasksForNode(String) - Method in class org.dataone.service.cn.replication.ReplicationTaskQueue
Returns the count of queued replica objects for the node specified by the nodeId parameter.
getEventid() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Get the event identifier
getFailureFactors(List<NodeReference>, boolean) - Method in class org.dataone.service.cn.replication.ReplicationPrioritizationStrategy
For the given node list, report the success factor as a surrogate for the nodes' demonstrated replication successes over a recent time period.
getId() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
getId() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
getInstance(NodeReference) - Static method in class org.dataone.service.cn.replication.ReplicationCommunication
 
getLastReplicationAttemptDate() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
getLastReplicationAttemptDateString() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
getMemberNodesInQueue() - Method in class org.dataone.service.cn.replication.ReplicationTaskQueue
Returns a Collection of NodeReference objects for member nodes that currently have queued replicas.
getNextExecution() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
getNextExecutionDateString() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
getNode(NodeReference) - Method in class org.dataone.service.cn.replication.ReplicationManager
Get a Node from the NodeRegistryService
getNodeId() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
getNodeReferences() - Method in class org.dataone.service.cn.replication.ReplicationManager
Get a list of NodeReferences from the NodeRegistryService
getObjectVersion(SystemMetadata) - Method in class org.dataone.service.cn.replication.ReplicationManager
returns list of versions for registered MNReplication services
getOriginatingNode() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Get the originating node
getOriginatingNodeSubject() - Method in class org.dataone.service.cn.replication.MNReplicationTask
For the given Replication task, return the Subject listed in the target node.
getPackagesToScan() - Method in class org.dataone.cn.data.repository.ReplicationPostgresRepositoryFactory
 
getPendingRequestFactors(List<NodeReference>, boolean) - Method in class org.dataone.service.cn.replication.ReplicationPrioritizationStrategy
For the given node list, report the pending request factor of each node.
getPid() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
getPid() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
getPid() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Get the object identifier to be replicated
getPotentialTargetNodes(Set<NodeReference>, SystemMetadata, ApiVersion) - Method in class org.dataone.service.cn.replication.ReplicationManager
determines which nodes are potential target nodes for the pid.
getReplicationAttempts() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
getReplicationManager() - Static method in class org.dataone.service.cn.replication.ReplicationFactory
 
getReplicationService() - Static method in class org.dataone.service.cn.replication.ReplicationFactory
 
getReplicationTaskQueue() - Static method in class org.dataone.service.cn.replication.ReplicationFactory
 
getReplicationTaskRepository() - Method in class org.dataone.cn.data.repository.ReplicationPostgresRepositoryFactory
 
getReplicationTaskRepository() - Static method in class org.dataone.service.cn.replication.ReplicationFactory
 
getReplicationTaskRepository() - Method in interface org.dataone.service.cn.replication.ReplicationRepositoryFactory
 
getReplicationTryHistoryRepository() - Method in class org.dataone.cn.data.repository.ReplicationPostgresRepositoryFactory
 
getReplicationTryHistoryRepository() - Static method in class org.dataone.service.cn.replication.ReplicationFactory
 
getReplicationTryHistoryRepository() - Method in interface org.dataone.service.cn.replication.ReplicationRepositoryFactory
 
getRetryCount() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Get the number of retries for this particular replication task;
getStatus() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
getSupportedReplicationVersion(Identifier, Node) - Method in class org.dataone.service.cn.replication.ReplicationManager
uses the authoritativeMemberNode of the object to determine which version to replicate with.
getSystemMetadata(Identifier) - Method in class org.dataone.service.cn.replication.ReplicationService
 
getTargetNode() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Get the target node
getTargetNodeSubject() - Method in class org.dataone.service.cn.replication.MNReplicationTask
For the given Replication task, return the Subject listed in the target node.
getTaskid() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Get the task identifier for this task
getTryCount() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
getV1Version() - Static method in class org.dataone.service.cn.replication.ApiVersion
 
getV2Version() - Static method in class org.dataone.service.cn.replication.ApiVersion
 
getVersion(String) - Static method in class org.dataone.service.cn.replication.ApiVersion
 

I

incrementReplicationAttempts() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
init() - Method in class org.dataone.service.cn.replication.ReplicationEventListener
Initialize the bean object
initContext() - Method in interface org.dataone.service.cn.replication.ReplicationRepositoryFactory
 
isProcessing() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
isV1(String) - Static method in class org.dataone.service.cn.replication.ApiVersion
 
isV2(String) - Static method in class org.dataone.service.cn.replication.ApiVersion
 

L

log - Static variable in class org.dataone.service.cn.replication.MNReplicationTask
 
log - Static variable in class org.dataone.service.cn.replication.RejectedReplicationTaskHandler
 
log - Static variable in class org.dataone.service.cn.replication.ReplicationCommunication
 
log - Static variable in class org.dataone.service.cn.replication.ReplicationManager
 
log - Static variable in class org.dataone.service.cn.replication.ReplicationPrioritizationStrategy
 
log - Static variable in class org.dataone.service.cn.replication.ReplicationService
 
logState() - Method in class org.dataone.service.cn.replication.ReplicationTaskQueue
 

M

markInProcess() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
markNew() - Method in class org.dataone.cn.data.repository.ReplicationTask
 
MNCommunication - Class in org.dataone.service.cn.replication.v1
 
MNCommunication() - Constructor for class org.dataone.service.cn.replication.v1.MNCommunication
 
MNCommunication - Class in org.dataone.service.cn.replication.v2
 
MNCommunication() - Constructor for class org.dataone.service.cn.replication.v2.MNCommunication
 
MNReplicationTask - Class in org.dataone.service.cn.replication
A single replication task to be queued and executed by the Replication Service.
MNReplicationTask() - Constructor for class org.dataone.service.cn.replication.MNReplicationTask
Constructor - create an empty replication task instance
MNReplicationTask(String, Identifier, NodeReference, NodeReference) - Constructor for class org.dataone.service.cn.replication.MNReplicationTask
Constructor - create a replication task instance

O

org.dataone.cn.data.repository - package org.dataone.cn.data.repository
 
org.dataone.service.cn.replication - package org.dataone.service.cn.replication
 
org.dataone.service.cn.replication.v1 - package org.dataone.service.cn.replication.v1
 
org.dataone.service.cn.replication.v2 - package org.dataone.service.cn.replication.v2
 

P

passesReplicationPolicies(Node, SystemMetadata) - Method in class org.dataone.service.cn.replication.ReplicationManager
examine the NodeReplicationPolocy of the Node and the ReplicationPolicy of the object to filter out incompatible targets.
prioritizeNodes(List<NodeReference>, SystemMetadata) - Method in class org.dataone.service.cn.replication.ReplicationPrioritizationStrategy
Prioritize a list of potential replica target nodes based on a number of factors including preferred/blocked node lists, pending request, failure, and bandwidth factors.
processAllTasksForMN(String) - Method in class org.dataone.service.cn.replication.ReplicationTaskQueue
Attempt to move each 'queued' replica to the 'requested' state for the member node specified by the memberNodeIdentifierValue parameter.

Q

QueuedReplicationAuditor - Class in org.dataone.service.cn.replication
Periodically runs to clear out the 'queued' replication tasks.
QueuedReplicationAuditor() - Constructor for class org.dataone.service.cn.replication.QueuedReplicationAuditor
 

R

rejectedExecution(Runnable, ThreadPoolExecutor) - Method in class org.dataone.service.cn.replication.RejectedReplicationTaskHandler
A handler method that adds rejected replication tasks back into the Hazelcast replication task queue to be completed later or by another coordinating node that may pick it up from the queue.
RejectedReplicationTaskHandler - Class in org.dataone.service.cn.replication
A class used to handle rejected replication tasks that were submitted to the executor service but failed to be executed due to resource constraints or other issues (like executor shutdown).
RejectedReplicationTaskHandler() - Constructor for class org.dataone.service.cn.replication.RejectedReplicationTaskHandler
Constructor to create a rejected replication task handler instance
ReplicationAttemptHistory - Class in org.dataone.cn.data.repository
 
ReplicationAttemptHistory() - Constructor for class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
ReplicationAttemptHistory(Identifier, NodeReference, Integer) - Constructor for class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
ReplicationAttemptHistoryRepository - Interface in org.dataone.cn.data.repository
 
ReplicationCommunication - Class in org.dataone.service.cn.replication
 
ReplicationCommunication() - Constructor for class org.dataone.service.cn.replication.ReplicationCommunication
 
ReplicationEventListener - Class in org.dataone.service.cn.replication
An event listener used to manage change events on the hzSystemMetadata map.
ReplicationEventListener() - Constructor for class org.dataone.service.cn.replication.ReplicationEventListener
Constructor: create a replication event listener that listens for entry events on the hzSystemMetadata map a queues the identifier key for replication task creation.
ReplicationFactory - Class in org.dataone.service.cn.replication
Factory class to provide consumers a handle on various replication objects
ReplicationManager - Class in org.dataone.service.cn.replication
A DataONE Coordinating Node implementation which manages replication queues and executes replication tasks.
ReplicationManager() - Constructor for class org.dataone.service.cn.replication.ReplicationManager
Constructor - singleton pattern, enforced by Spring application.
ReplicationManager(ReplicationRepositoryFactory) - Constructor for class org.dataone.service.cn.replication.ReplicationManager
A for-testing-purposes constructor to get around configuration complications
ReplicationPostgresRepositoryFactory - Class in org.dataone.cn.data.repository
 
ReplicationPostgresRepositoryFactory() - Constructor for class org.dataone.cn.data.repository.ReplicationPostgresRepositoryFactory
 
ReplicationPrioritizationStrategy - Class in org.dataone.service.cn.replication
ReplicationPrioritizationStrategy encapsulates the logic and calculations used to prioritize target Member Nodes as replication targets.
ReplicationPrioritizationStrategy() - Constructor for class org.dataone.service.cn.replication.ReplicationPrioritizationStrategy
Constructor: create a prioritization strategy
ReplicationRepositoryFactory - Interface in org.dataone.service.cn.replication
 
replicationService - Variable in class org.dataone.service.cn.replication.ReplicationCommunication
 
ReplicationService - Class in org.dataone.service.cn.replication
Encapsulation of common operations involving replica system metadata objects.
ReplicationService() - Constructor for class org.dataone.service.cn.replication.ReplicationService
 
ReplicationStatusMonitor - Class in org.dataone.service.cn.replication
Monitors the replica (table) to summarize the number of replicas by target node and replication status.
ReplicationStatusMonitor() - Constructor for class org.dataone.service.cn.replication.ReplicationStatusMonitor
 
ReplicationTask - Class in org.dataone.cn.data.repository
 
ReplicationTask() - Constructor for class org.dataone.cn.data.repository.ReplicationTask
 
ReplicationTask(Identifier) - Constructor for class org.dataone.cn.data.repository.ReplicationTask
 
ReplicationTaskMonitor - Class in org.dataone.service.cn.replication
 
ReplicationTaskMonitor() - Constructor for class org.dataone.service.cn.replication.ReplicationTaskMonitor
 
ReplicationTaskProcessor - Class in org.dataone.service.cn.replication
 
ReplicationTaskProcessor() - Constructor for class org.dataone.service.cn.replication.ReplicationTaskProcessor
 
ReplicationTaskQueue - Class in org.dataone.service.cn.replication
A member node replication work queue.
ReplicationTaskQueue() - Constructor for class org.dataone.service.cn.replication.ReplicationTaskQueue
 
ReplicationTaskRepository - Interface in org.dataone.cn.data.repository
 
requestQueuedReplication(Identifier, NodeReference) - Method in class org.dataone.service.cn.replication.ReplicationService
Handles moving a 'queued' replication object into 'requested' state.
requestReplication(NodeReference, SystemMetadata) - Method in class org.dataone.service.cn.replication.ReplicationCommunication
 
requestReplication(NodeReference, SystemMetadata) - Method in class org.dataone.service.cn.replication.v1.MNCommunication
 
requestReplication(NodeReference, SystemMetadata) - Method in class org.dataone.service.cn.replication.v2.MNCommunication
 
run() - Method in class org.dataone.service.cn.replication.MNReplicationTask
Implements the Runnable interface, but the task is actually called via the Callable interface.
run() - Method in class org.dataone.service.cn.replication.QueuedReplicationAuditor
 
run() - Method in class org.dataone.service.cn.replication.ReplicationStatusMonitor
 
run() - Method in class org.dataone.service.cn.replication.ReplicationTaskMonitor
queries the replication task repository for a page of 'NEW' tasks, and sends them to the ReplicationManager for execution.
run() - Method in class org.dataone.service.cn.replication.ReplicationTaskProcessor
queries the replication task repository for a page of 'NEW' tasks, and sends them to the ReplicationManager for execution.
run() - Method in class org.dataone.service.cn.replication.StaleReplicationRequestAuditor
 

S

setApiLabel(String) - Method in class org.dataone.service.cn.replication.ApiVersion
 
setApiValue(int) - Method in class org.dataone.service.cn.replication.ApiVersion
 
setCnReplication(CNReplication) - Method in class org.dataone.service.cn.replication.ReplicationManager
 
setEventid(String) - Method in class org.dataone.service.cn.replication.MNReplicationTask
Set the event identifier
setLastReplicationAttemptDate(long) - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
setNextExecution(long) - Method in class org.dataone.cn.data.repository.ReplicationTask
 
setNodeId(String) - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
setOriginatingNode(NodeReference) - Method in class org.dataone.service.cn.replication.MNReplicationTask
Set the originating node
setOriginatingNodeSubject(String) - Method in class org.dataone.service.cn.replication.MNReplicationTask
Set the target node subject identifying the node
setPid(String) - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
setPid(String) - Method in class org.dataone.cn.data.repository.ReplicationTask
 
setReplicationAttempts(Integer) - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
setReplicaToCompleted(Identifier, NodeReference) - Method in class org.dataone.service.cn.replication.ReplicationService
 
setReplicaToRequested(Identifier, NodeReference) - Method in class org.dataone.service.cn.replication.ReplicationService
 
setRetryCount(int) - Method in class org.dataone.service.cn.replication.MNReplicationTask
Set the number of retries for this particular replication task
setStatus(String) - Method in class org.dataone.cn.data.repository.ReplicationTask
 
setTargetNode(NodeReference) - Method in class org.dataone.service.cn.replication.MNReplicationTask
Set the target node
setTargetNodeSubject(String) - Method in class org.dataone.service.cn.replication.MNReplicationTask
Set the target node subject identifying the node
setTaskid(String) - Method in class org.dataone.service.cn.replication.MNReplicationTask
Set the task identifier for this task
setTryCount(int) - Method in class org.dataone.cn.data.repository.ReplicationTask
 
StaleReplicationRequestAuditor - Class in org.dataone.service.cn.replication
Auditor class to inspect Member Node replication requests that have been in request status for longer than a specific period of time (default 1 hour).
StaleReplicationRequestAuditor() - Constructor for class org.dataone.service.cn.replication.StaleReplicationRequestAuditor
 
STATUS_IN_PROCESS - Static variable in class org.dataone.cn.data.repository.ReplicationTask
 
STATUS_NEW - Static variable in class org.dataone.cn.data.repository.ReplicationTask
 

T

targetNodeSupportsReplication(Node, ApiVersion) - Method in class org.dataone.service.cn.replication.ReplicationManager
determines whether or not the passed in node supports replication at the version level specified.
toString() - Method in class org.dataone.cn.data.repository.ReplicationAttemptHistory
 
toString() - Method in class org.dataone.cn.data.repository.ReplicationTask
 

U

updateReplicationMetadata(Identifier, Replica) - Method in class org.dataone.service.cn.replication.ReplicationService
Update the replica metadata against the CN router address rather than the local CN address.

V

V1 - Static variable in class org.dataone.service.cn.replication.ApiVersion
 
V2 - Static variable in class org.dataone.service.cn.replication.ApiVersion
 
A C D E F G I L M O P Q R S T U V 
Skip navigation links

Copyright © 2018. All rights reserved.