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