A B C D E F G H I J K L M N O P Q R S T U V Z
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- Access - Class in org.cdlib.mrt.zk
-
Class to manage a Merritt Access Assembly Request.
- Access - org.cdlib.mrt.zk.QueueItem.ZkPaths
- Access - org.cdlib.mrt.zk.QueueItem.ZkPrefixes
- Access(Access.Queues, String) - Constructor for class org.cdlib.mrt.zk.Access
- Access(Access.Queues, String, JSONObject) - Constructor for class org.cdlib.mrt.zk.Access
- ACCESS_TOKEN - org.cdlib.mrt.zk.ZKKey
-
Access assembly token data
- Access.Queues - Enum in org.cdlib.mrt.zk
-
Access Assembly Queue names
- AccessAnticipatedAvailabilityTime - org.cdlib.mrt.zk.MerrittJsonKey
- AccessCloudContentByte - org.cdlib.mrt.zk.MerrittJsonKey
- AccessDeliveryNode - org.cdlib.mrt.zk.MerrittJsonKey
- AccessLarge - org.cdlib.mrt.zk.QueueItem.ZkPaths
- AccessSmall - org.cdlib.mrt.zk.QueueItem.ZkPaths
- AccessState - Enum in org.cdlib.mrt.zk
-
Access Assembly State Transitions
- AccessToken - org.cdlib.mrt.zk.MerrittJsonKey
- AccessTokenStatus - org.cdlib.mrt.zk.MerrittJsonKey
- AccessUrl - org.cdlib.mrt.zk.MerrittJsonKey
- acl - Static variable in class org.cdlib.mrt.zk.QueueItemHelper
- acquireBatchForReporting(ZooKeeper) - Static method in class org.cdlib.mrt.zk.Batch
- acquireJob(ZooKeeper, IngestState) - Static method in class org.cdlib.mrt.zk.Job
- acquirePendingAssembly(ZooKeeper, Access.Queues) - Static method in class org.cdlib.mrt.zk.Access
- acquirePendingBatch(ZooKeeper) - Static method in class org.cdlib.mrt.zk.Batch
- anticipatedAvailabilityTime() - Method in class org.cdlib.mrt.zk.Access
- asBytes(String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
B
- Batch - Class in org.cdlib.mrt.zk
-
Class to manage a Merritt Ingest Batch in the Batch Queue.
- Batch - org.cdlib.mrt.zk.QueueItem.ZkPaths
- Batch - org.cdlib.mrt.zk.QueueItem.ZkPrefixes
- Batch(String) - Constructor for class org.cdlib.mrt.zk.Batch
- Batch(String, JSONObject) - Constructor for class org.cdlib.mrt.zk.Batch
- BATCH_STATUS_REPORT - org.cdlib.mrt.zk.ZKKey
-
JSON node summarizing a report sent to the depositor detaining completed and failed jobs for a batch.
- BATCH_SUBMISSION - org.cdlib.mrt.zk.ZKKey
-
Read-only JSON node containing the parameters that initiated a submission.
- BatchId - org.cdlib.mrt.zk.MerrittJsonKey
- BatchPayloadFileName - org.cdlib.mrt.zk.MerrittJsonKey
- BatchState - Enum in org.cdlib.mrt.zk
-
Batch State Transitions
- batchStatePath() - Method in class org.cdlib.mrt.zk.Job
- batchStateSubpath() - Method in class org.cdlib.mrt.zk.Job
- BatchType - org.cdlib.mrt.zk.MerrittJsonKey
- batchUuid() - Method in class org.cdlib.mrt.zk.Batch
- batchUuidPath(String) - Static method in class org.cdlib.mrt.zk.Batch
- BatchUuids - org.cdlib.mrt.zk.QueueItem.ZkPaths
- bid() - Method in class org.cdlib.mrt.zk.Job
C
- checkLockCollection(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- checkLockIngestQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- checkLockLargeAccessQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- checkLockObjectInventory(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- checkLockObjectStorage(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- checkLockSmallAccessQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- cloudContentByte() - Method in class org.cdlib.mrt.zk.Access
- Completed - org.cdlib.mrt.zk.AccessState
-
All jobs COMPLETED
- Completed - org.cdlib.mrt.zk.BatchState
-
All jobs COMPLETED
- Completed - org.cdlib.mrt.zk.JobState
-
Storage and inventory are complete, cleanup job folder
- Completed - org.cdlib.mrt.zk.QueueItem.BatchJobStates
- create(ZooKeeper, String, byte[]) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- createAssembly(ZooKeeper, Access.Queues, JSONObject) - Static method in class org.cdlib.mrt.zk.Access
- createBatch(ZooKeeper, JSONObject) - Static method in class org.cdlib.mrt.zk.Batch
- createData(ZooKeeper, ZKKey, Object) - Method in class org.cdlib.mrt.zk.QueueItem
- createEphemeral(ZooKeeper, String, byte[]) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- createId(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- createIfNeeded(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- createIfNeededForgiving(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- createJob(ZooKeeper, String, int, JSONObject) - Static method in class org.cdlib.mrt.zk.Job
- createJob(ZooKeeper, String, int, JSONObject, JSONObject) - Static method in class org.cdlib.mrt.zk.Job
- createJob(ZooKeeper, String, int, JSONObject, JSONObject, JSONObject) - Static method in class org.cdlib.mrt.zk.Job
- createJob(ZooKeeper, String, JSONObject) - Static method in class org.cdlib.mrt.zk.Job
- createJobConfiguration(String, String, String, String, String) - Static method in class org.cdlib.mrt.zk.Job
- createJobIdentifiers(String, String) - Static method in class org.cdlib.mrt.zk.Job
- createJobMetadata(String, String, String, String) - Static method in class org.cdlib.mrt.zk.Job
- createOrSetData(ZooKeeper, ZKKey, Object) - Method in class org.cdlib.mrt.zk.QueueItem
- createSequential(ZooKeeper, String, byte[]) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
D
- data - Variable in class org.cdlib.mrt.zk.QueueItem
- data() - Method in class org.cdlib.mrt.zk.QueueItem
- delete(ZooKeeper) - Method in class org.cdlib.mrt.zk.Access
- delete(ZooKeeper) - Method in class org.cdlib.mrt.zk.Batch
- delete(ZooKeeper) - Method in class org.cdlib.mrt.zk.Job
- delete(ZooKeeper) - Method in class org.cdlib.mrt.zk.QueueItem
- delete(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- deleteAll(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- deleteCompletedBatches(ZooKeeper) - Static method in class org.cdlib.mrt.zk.Batch
- Deleted - org.cdlib.mrt.zk.AccessState
- Deleted - org.cdlib.mrt.zk.BatchState
- Deleted - org.cdlib.mrt.zk.JobState
- Deleted - org.cdlib.mrt.zk.QueueItem.BatchJobStates
- deliveryNode() - Method in class org.cdlib.mrt.zk.Access
- dir() - Method in class org.cdlib.mrt.zk.Access
- dir() - Method in class org.cdlib.mrt.zk.Batch
- dir() - Method in class org.cdlib.mrt.zk.Job
- dir() - Method in class org.cdlib.mrt.zk.QueueItem
- dir(Access.Queues) - Static method in class org.cdlib.mrt.zk.Access
- Downloading - org.cdlib.mrt.zk.JobState
-
One or more downloads is in progress.
E
- empty - Static variable in class org.cdlib.mrt.zk.QueueItemHelper
- ercWhat() - Method in class org.cdlib.mrt.zk.Job
- ErcWhat - org.cdlib.mrt.zk.MerrittJsonKey
- ercWhen() - Method in class org.cdlib.mrt.zk.Job
- ErcWhen - org.cdlib.mrt.zk.MerrittJsonKey
- ercWhere() - Method in class org.cdlib.mrt.zk.Job
- ErcWhere - org.cdlib.mrt.zk.MerrittJsonKey
- ercWho() - Method in class org.cdlib.mrt.zk.Job
- ErcWho - org.cdlib.mrt.zk.MerrittJsonKey
- Estimating - org.cdlib.mrt.zk.JobState
-
Perform HEAD requests for all content to estimate the size of the ingest.
- exists(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
F
- fail() - Method in interface org.cdlib.mrt.zk.IngestState
- Failed - org.cdlib.mrt.zk.AccessState
-
At least one job FAILED
- Failed - org.cdlib.mrt.zk.BatchState
-
At least one job FAILED
- Failed - org.cdlib.mrt.zk.JobState
-
The queue will track the last successful step so that the job can be resumed at the appropriate step.
- Failed - org.cdlib.mrt.zk.QueueItem.BatchJobStates
- findByUuid(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.Batch
G
- getCompletedJobs(ZooKeeper) - Method in class org.cdlib.mrt.zk.Batch
- getDeletedJobs(ZooKeeper) - Method in class org.cdlib.mrt.zk.Batch
- getFailedJobs(ZooKeeper) - Method in class org.cdlib.mrt.zk.Batch
- getJobs(ZooKeeper, QueueItem.BatchJobStates) - Method in class org.cdlib.mrt.zk.Batch
- getProcessingJobs(ZooKeeper) - Method in class org.cdlib.mrt.zk.Batch
H
- hasFailure() - Method in class org.cdlib.mrt.zk.Batch
-
Indicate that a batch contains a failed job in the Job Queue.
- Held - org.cdlib.mrt.zk.BatchState
-
Collection is HELD.
- Held - org.cdlib.mrt.zk.JobState
-
Since Job was queued, the collection has been put into a HELD state.
I
- id() - Method in class org.cdlib.mrt.zk.QueueItem
- IngestState - Interface in org.cdlib.mrt.zk
-
Common interface for Ingest Queue State Enums
- initLocks(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- initNodes(ZooKeeper) - Static method in class org.cdlib.mrt.zk.Access
- initNodes(ZooKeeper) - Static method in class org.cdlib.mrt.zk.Job
- initStatus() - Static method in class org.cdlib.mrt.zk.Access
- initStatus() - Static method in class org.cdlib.mrt.zk.Batch
- initStatus() - Static method in class org.cdlib.mrt.zk.Job
- intProperty(ZooKeeper, ZKKey) - Method in class org.cdlib.mrt.zk.QueueItem
- inventoryManifestUrl() - Method in class org.cdlib.mrt.zk.Job
- InventoryManifestUrl - org.cdlib.mrt.zk.MerrittJsonKey
- inventoryMode() - Method in class org.cdlib.mrt.zk.Job
- InventoryMode - org.cdlib.mrt.zk.MerrittJsonKey
- isDeletable() - Method in interface org.cdlib.mrt.zk.IngestState
J
- jid() - Method in class org.cdlib.mrt.zk.Job
- JID - org.cdlib.mrt.zk.MerrittJsonKey
- Job - Class in org.cdlib.mrt.zk
-
Class to manage a Merritt Ingest Job in the Job Queue.
- Job - org.cdlib.mrt.zk.QueueItem.ZkPaths
- Job - org.cdlib.mrt.zk.QueueItem.ZkPrefixes
- Job(String) - Constructor for class org.cdlib.mrt.zk.Job
- Job(String, String) - Constructor for class org.cdlib.mrt.zk.Job
- Job(String, String, JSONObject) - Constructor for class org.cdlib.mrt.zk.Job
- JOB_BID - org.cdlib.mrt.zk.ZKKey
-
String node containing the batch id for the job
- JOB_CONFIGURATION - org.cdlib.mrt.zk.ZKKey
-
Read-only JSON node containing the parameters for a specific job.
- JOB_IDENTIFIERS - org.cdlib.mrt.zk.ZKKey
-
JSON node containing the primary id and local id for a job.
- JOB_INVENTORY - org.cdlib.mrt.zk.ZKKey
-
inventory parameters
- JOB_METADATA - org.cdlib.mrt.zk.ZKKey
-
JSON node containing the primary id and local id for a job.
- JOB_PRIORITY - org.cdlib.mrt.zk.ZKKey
-
Integer node containing the priority assigned to the job.
- JOB_SPACE_NEEDED - org.cdlib.mrt.zk.ZKKey
-
Long node containing the bytes of cloud storage to be used by the job.
- JobPayloadType - org.cdlib.mrt.zk.MerrittJsonKey
- JobPayloadUrl - org.cdlib.mrt.zk.MerrittJsonKey
- JobResponseType - org.cdlib.mrt.zk.MerrittJsonKey
- JobState - Enum in org.cdlib.mrt.zk
-
Job State Transitions
- jobStatePath() - Method in class org.cdlib.mrt.zk.Job
- JobStates - org.cdlib.mrt.zk.QueueItem.ZkPaths
- jsonDataProperty(JSONObject, MerrittJsonKey, Object) - Static method in class org.cdlib.mrt.zk.QueueItem
- jsonIntProperty(JSONObject, MerrittJsonKey, int) - Static method in class org.cdlib.mrt.zk.QueueItem
- jsonLongProperty(JSONObject, MerrittJsonKey, long) - Static method in class org.cdlib.mrt.zk.QueueItem
- jsonProperty(ZooKeeper, ZKKey) - Method in class org.cdlib.mrt.zk.QueueItem
- jsonStringProperty(JSONObject, MerrittJsonKey, String) - Static method in class org.cdlib.mrt.zk.QueueItem
K
- key() - Method in enum org.cdlib.mrt.zk.MerrittJsonKey
- key() - Method in enum org.cdlib.mrt.zk.ZKKey
L
- large - org.cdlib.mrt.zk.Access.Queues
- LastModified - org.cdlib.mrt.zk.MerrittJsonKey
- LastSuccessfulStatus - org.cdlib.mrt.zk.MerrittJsonKey
- listJobs(ZooKeeper, Access.Queues, AccessState) - Static method in class org.cdlib.mrt.zk.Access
- listJobs(ZooKeeper, IngestState) - Static method in class org.cdlib.mrt.zk.Job
- load(ZooKeeper) - Method in class org.cdlib.mrt.zk.QueueItem
- loadHasFailure(ZooKeeper) - Method in class org.cdlib.mrt.zk.Batch
- loadProperties(ZooKeeper) - Method in class org.cdlib.mrt.zk.Access
- loadProperties(ZooKeeper) - Method in class org.cdlib.mrt.zk.Batch
- loadProperties(ZooKeeper) - Method in class org.cdlib.mrt.zk.Job
- loadProperties(ZooKeeper) - Method in class org.cdlib.mrt.zk.QueueItem
- loadStatus(ZooKeeper, JSONObject) - Method in class org.cdlib.mrt.zk.Job
- loadStatus(ZooKeeper, JSONObject) - Method in class org.cdlib.mrt.zk.QueueItem
- localId() - Method in class org.cdlib.mrt.zk.Job
- LocalId - org.cdlib.mrt.zk.MerrittJsonKey
- lock(ZooKeeper) - Method in class org.cdlib.mrt.zk.QueueItem
- LOCK - org.cdlib.mrt.zk.ZKKey
-
Empty Ephemeral node that indicates that a Batch or Job has been locked by a consumer daemon
- lockCollection(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- lockIngestQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- lockLargeAccessQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- lockObjectInventory(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- lockObjectStorage(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- Locks - org.cdlib.mrt.zk.QueueItem.ZkPaths
- LocksCollections - org.cdlib.mrt.zk.QueueItem.ZkPaths
- LocksInventory - org.cdlib.mrt.zk.QueueItem.ZkPaths
- lockSmallAccessQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- LocksQueue - org.cdlib.mrt.zk.QueueItem.ZkPaths
- LocksQueueAccessLarge - org.cdlib.mrt.zk.QueueItem.ZkPaths
- LocksQueueAccessSmall - org.cdlib.mrt.zk.QueueItem.ZkPaths
- LocksQueueIngest - org.cdlib.mrt.zk.QueueItem.ZkPaths
- LocksStorage - org.cdlib.mrt.zk.QueueItem.ZkPaths
- longProperty(ZooKeeper, ZKKey) - Method in class org.cdlib.mrt.zk.QueueItem
M
- main(String[]) - Static method in class org.cdlib.mrt.zk.Batch
- makePath(ZKKey) - Method in class org.cdlib.mrt.zk.QueueItem
- MerrittJsonKey - Enum in org.cdlib.mrt.zk
-
Lookup key names for properties stored as JSON within ZooKeeper nodes.
- MerrittLocks - Class in org.cdlib.mrt.zk
-
Static methods to set and release Merritt Locks.
- MerrittLocks() - Constructor for class org.cdlib.mrt.zk.MerrittLocks
- MerrittStateError - Exception in org.cdlib.mrt.zk
-
Exception indicates that an illegal operation was invoked on an object with an incompatible state (ie attempting to delete a Job or Batch that is not in a deleteable state)
- MerrittStateError(String) - Constructor for exception org.cdlib.mrt.zk.MerrittStateError
- MerrittZKNodeInvalid - Exception in org.cdlib.mrt.zk
-
Exception thown when attempting to modify the data payload for a ZooKeeper node.
- MerrittZKNodeInvalid(String) - Constructor for exception org.cdlib.mrt.zk.MerrittZKNodeInvalid
- Message - org.cdlib.mrt.zk.MerrittJsonKey
N
- name() - Method in interface org.cdlib.mrt.zk.IngestState
- nextStates() - Method in enum org.cdlib.mrt.zk.AccessState
- nextStates() - Method in enum org.cdlib.mrt.zk.BatchState
- nextStates() - Method in interface org.cdlib.mrt.zk.IngestState
- nextStates() - Method in enum org.cdlib.mrt.zk.JobState
- Notify - org.cdlib.mrt.zk.JobState
-
Invoke callback if needed Notify batch handler that the job is complete
- now() - Static method in class org.cdlib.mrt.zk.QueueItemHelper
O
- optJsonProperty(ZooKeeper, ZKKey) - Method in class org.cdlib.mrt.zk.QueueItem
- optStringProperty(ZooKeeper, ZKKey) - Method in class org.cdlib.mrt.zk.QueueItem
- org.cdlib.mrt.zk - package org.cdlib.mrt.zk
-
Merritt Queue Design
P
- path - Variable in enum org.cdlib.mrt.zk.QueueItem.BatchJobStates
- path - Variable in enum org.cdlib.mrt.zk.QueueItem.ZkPaths
- path() - Method in class org.cdlib.mrt.zk.QueueItem
- pathToString(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- payloadType() - Method in class org.cdlib.mrt.zk.Job
- payloadUrl() - Method in class org.cdlib.mrt.zk.Job
- Pending - org.cdlib.mrt.zk.AccessState
-
Assembly is ready to be processed
- Pending - org.cdlib.mrt.zk.BatchState
-
Batch is ready to be processed
- Pending - org.cdlib.mrt.zk.JobState
-
Job is waiting to be acquired by the queue
- prefix - Variable in enum org.cdlib.mrt.zk.QueueItem.ZkPrefixes
- prefix() - Method in class org.cdlib.mrt.zk.Access
- prefix() - Method in class org.cdlib.mrt.zk.Batch
- prefix() - Method in class org.cdlib.mrt.zk.Job
- prefix() - Method in class org.cdlib.mrt.zk.QueueItem
- prefixPath() - Static method in class org.cdlib.mrt.zk.Batch
- prefixPath() - Static method in class org.cdlib.mrt.zk.Job
- prefixPath(Access.Queues) - Static method in class org.cdlib.mrt.zk.Access
- primaryId() - Method in class org.cdlib.mrt.zk.Job
- PrimaryId - org.cdlib.mrt.zk.MerrittJsonKey
- priority() - Method in class org.cdlib.mrt.zk.Job
- PRIORITY - Static variable in class org.cdlib.mrt.zk.Job
- Processing - org.cdlib.mrt.zk.AccessState
-
Payload is analyzed.
- Processing - org.cdlib.mrt.zk.BatchState
-
Payload is analyzed.
- Processing - org.cdlib.mrt.zk.JobState
-
All downloads complete; perform Merritt Ingest (validate checksum, mint, create system files, notify storage)
- Processing - org.cdlib.mrt.zk.QueueItem.BatchJobStates
- profileName() - Method in class org.cdlib.mrt.zk.Job
- ProfileName - org.cdlib.mrt.zk.MerrittJsonKey
- Provisioning - org.cdlib.mrt.zk.JobState
-
Once dynamic provisioning is implemented (ie zfs provisioning), wait for dedicated file system to be provisioned.
Q
- QueueItem - Class in org.cdlib.mrt.zk
-
Base Class for Common functions for Merritt Ingest Batches and Merritt Ingest Jobs.
- QueueItem(String) - Constructor for class org.cdlib.mrt.zk.QueueItem
- QueueItem(String, JSONObject) - Constructor for class org.cdlib.mrt.zk.QueueItem
- QueueItem.BatchJobStates - Enum in org.cdlib.mrt.zk
-
Standardized path names for Merritt Zookeeper nodes
- QueueItem.ZkPaths - Enum in org.cdlib.mrt.zk
-
Standardized path names for Merritt Zookeeper nodes
- QueueItem.ZkPrefixes - Enum in org.cdlib.mrt.zk
-
Standardized prefix names for Merritt Zookeeper sequential nodes
- QueueItemHelper - Class in org.cdlib.mrt.zk
-
The static methods in this class also provides a simplified interface for common ZooKeeper API calls.
- QueueItemHelper() - Constructor for class org.cdlib.mrt.zk.QueueItemHelper
R
- Recording - org.cdlib.mrt.zk.JobState
-
Storage is complete; ready for Inventory.
- Reporting - org.cdlib.mrt.zk.BatchState
-
All jobs have COMPLETED or FAILED, a summary e-mail is sent to the depositor.
- resolveStatus(String) - Method in class org.cdlib.mrt.zk.Access
- resolveStatus(String) - Method in class org.cdlib.mrt.zk.Batch
- resolveStatus(String) - Method in class org.cdlib.mrt.zk.Job
- resolveStatus(String) - Method in class org.cdlib.mrt.zk.QueueItem
- responseType() - Method in class org.cdlib.mrt.zk.Job
- retryCount() - Method in class org.cdlib.mrt.zk.Job
- RetryCount - org.cdlib.mrt.zk.MerrittJsonKey
- ROOT - org.cdlib.mrt.zk.ZKKey
-
Root path for a QueueItem
S
- serialize(Object) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- serializeAsBytes(Object) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- setBatchStatePath(ZooKeeper) - Method in class org.cdlib.mrt.zk.Job
- setData(ZooKeeper, String, byte[]) - Static method in class org.cdlib.mrt.zk.QueueItemHelper
- setData(ZooKeeper, ZKKey, Object) - Method in class org.cdlib.mrt.zk.QueueItem
- setIdentifiers(ZooKeeper, JSONObject) - Method in class org.cdlib.mrt.zk.Job
- setInventory(ZooKeeper, String, String) - Method in class org.cdlib.mrt.zk.Job
- setJobStatePath(ZooKeeper) - Method in class org.cdlib.mrt.zk.Job
- setMetadata(ZooKeeper, JSONObject) - Method in class org.cdlib.mrt.zk.Job
- setSpaceNeeded(ZooKeeper, long) - Method in class org.cdlib.mrt.zk.Job
- setStatus(ZooKeeper, IngestState) - Method in class org.cdlib.mrt.zk.QueueItem
- setStatus(ZooKeeper, IngestState, String) - Method in class org.cdlib.mrt.zk.QueueItem
- setStatusTrigger(ZooKeeper) - Method in class org.cdlib.mrt.zk.Job
- setStatusTrigger(ZooKeeper) - Method in class org.cdlib.mrt.zk.QueueItem
- setStatusWithPriority(ZooKeeper, IngestState, int) - Method in class org.cdlib.mrt.zk.Job
- setStatusWithRetry(ZooKeeper, IngestState) - Method in class org.cdlib.mrt.zk.Job
- small - org.cdlib.mrt.zk.Access.Queues
- spaceNeeded() - Method in class org.cdlib.mrt.zk.Job
- stateChange(IngestState) - Method in enum org.cdlib.mrt.zk.AccessState
- stateChange(IngestState) - Method in enum org.cdlib.mrt.zk.BatchState
- stateChange(IngestState) - Method in interface org.cdlib.mrt.zk.IngestState
- stateChange(IngestState) - Method in enum org.cdlib.mrt.zk.JobState
- stateChangeAllowed(IngestState) - Method in interface org.cdlib.mrt.zk.IngestState
- states() - Method in class org.cdlib.mrt.zk.Access
- states() - Method in class org.cdlib.mrt.zk.Batch
- states() - Method in class org.cdlib.mrt.zk.Job
- states() - Method in class org.cdlib.mrt.zk.QueueItem
- STATES - org.cdlib.mrt.zk.ZKKey
-
Parent node of state-specific nodes for a Batch or for a Job.
- statesAsJson(IngestState[]) - Static method in interface org.cdlib.mrt.zk.IngestState
- status() - Method in class org.cdlib.mrt.zk.QueueItem
- Status - org.cdlib.mrt.zk.MerrittJsonKey
- STATUS - org.cdlib.mrt.zk.ZKKey
-
JSON node uses to store current state for a Job or a Batch
- statusObject(IngestState) - Method in class org.cdlib.mrt.zk.Job
- statusObject(IngestState) - Method in class org.cdlib.mrt.zk.QueueItem
- stringProperty(ZooKeeper, ZKKey) - Method in class org.cdlib.mrt.zk.QueueItem
- SubmissionMode - org.cdlib.mrt.zk.MerrittJsonKey
- submitter() - Method in class org.cdlib.mrt.zk.Job
- Submitter - org.cdlib.mrt.zk.MerrittJsonKey
- success() - Method in interface org.cdlib.mrt.zk.IngestState
T
- token() - Method in class org.cdlib.mrt.zk.Access
- tokenStatus() - Method in class org.cdlib.mrt.zk.Access
U
- unlock(ZooKeeper) - Method in class org.cdlib.mrt.zk.QueueItem
- unlockCollection(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- unlockIngestQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- unlockLargeAccessQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- unlockObjectInventory(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- unlockObjectStorage(ZooKeeper, String) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- unlockSmallAccessQueue(ZooKeeper) - Static method in class org.cdlib.mrt.zk.MerrittLocks
- UpdateReporting - org.cdlib.mrt.zk.BatchState
-
Determine if any previously FAILED jobs are not complete.
- url() - Method in class org.cdlib.mrt.zk.Access
V
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.Access.Queues
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.AccessState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.BatchState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.JobState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.MerrittJsonKey
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.QueueItem.BatchJobStates
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.QueueItem.ZkPaths
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.QueueItem.ZkPrefixes
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.cdlib.mrt.zk.ZKKey
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.cdlib.mrt.zk.Access.Queues
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.AccessState
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.BatchState
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.JobState
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.MerrittJsonKey
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.QueueItem.BatchJobStates
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.QueueItem.ZkPaths
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.QueueItem.ZkPrefixes
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum org.cdlib.mrt.zk.ZKKey
-
Returns an array containing the constants of this enum type, in the order they are declared.
Z
- ZKKey - Enum in org.cdlib.mrt.zk
-
Defines relative pathnames to ZooKeeper nodes for a Batch or a Job.
All Classes All Packages