Package org.cdlib.mrt.zk

Class Access

java.lang.Object

org.cdlib.mrt.zk.QueueItem

org.cdlib.mrt.zk.Access

public class Access
extends QueueItem

Class to manage a Merritt Access Assembly Request.

See Also:

State Transition Design

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Access.Queues	Access Assembly Queue names

Nested classes/interfaces inherited from class org.cdlib.mrt.zk.QueueItem

QueueItem.BatchJobStates, QueueItem.ZkPaths, QueueItem.ZkPrefixes

Field Summary

Fields inherited from class org.cdlib.mrt.zk.QueueItem

data

Constructor Summary

Constructors

Constructor	Description
Access(Access.Queues queueName, String id)
Access(Access.Queues queueName, String id, org.json.JSONObject data)

Method Summary

Modifier and Type	Method	Description
static Access	acquirePendingAssembly(org.apache.zookeeper.ZooKeeper client, Access.Queues queueName)
String	anticipatedAvailabilityTime()
long	cloudContentByte()
static Access	createAssembly(org.apache.zookeeper.ZooKeeper client, Access.Queues queueName, org.json.JSONObject token)
void	delete(org.apache.zookeeper.ZooKeeper client)
int	deliveryNode()
String	dir()
static String	dir(Access.Queues queueName)
static void	initNodes(org.apache.zookeeper.ZooKeeper client)
static IngestState	initStatus()
static List<Access>	listJobs(org.apache.zookeeper.ZooKeeper client, Access.Queues queueName, AccessState state)
void	loadProperties(org.apache.zookeeper.ZooKeeper client)
String	prefix()
static String	prefixPath(Access.Queues queueName)
IngestState	resolveStatus(String s)
IngestState[]	states()
String	token()
String	tokenStatus()
String	url()

Methods inherited from class org.cdlib.mrt.zk.QueueItem

createData, createOrSetData, data, id, intProperty, jsonDataProperty, jsonIntProperty, jsonLongProperty, jsonProperty, jsonStringProperty, load, loadStatus, lock, longProperty, makePath, optJsonProperty, optStringProperty, path, setData, setStatus, setStatus, setStatusTrigger, status, statusObject, stringProperty, unlock

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Access

public Access(Access.Queues queueName,
              String id)

Parameters:

queueName - indicates large or small access queue

id - Unique id assigned to an assembly request. This id is generated by creating a sequential queue item.

Access

public Access(Access.Queues queueName,
              String id,
              org.json.JSONObject data)

Parameters:

queueName - indicates large or small access queue

id - Unique id assigned to an assembly request. This id is generated by creating a sequential item.

data - JSON representation of an ingest initiated by a Merritt depostor.

Method Detail

dir

public static String dir(Access.Queues queueName)

dir

public String dir()

Specified by:

dir in class QueueItem

prefix

public String prefix()

Specified by:

prefix in class QueueItem

prefixPath

public static String prefixPath(Access.Queues queueName)

initStatus

public static IngestState initStatus()

resolveStatus

public IngestState resolveStatus(String s)

Specified by:

resolveStatus in class QueueItem

loadProperties

public void loadProperties(org.apache.zookeeper.ZooKeeper client)
                    throws org.apache.zookeeper.KeeperException,
                           InterruptedException,
                           MerrittZKNodeInvalid

Overrides:

loadProperties in class QueueItem

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

MerrittZKNodeInvalid

token

public String token()

deliveryNode

public int deliveryNode()

cloudContentByte

public long cloudContentByte()

tokenStatus

public String tokenStatus()

url

public String url()

anticipatedAvailabilityTime

public String anticipatedAvailabilityTime()

states

public IngestState[] states()

Specified by:

states in class QueueItem

createAssembly

public static Access createAssembly(org.apache.zookeeper.ZooKeeper client,
                                    Access.Queues queueName,
                                    org.json.JSONObject token)
                             throws org.apache.zookeeper.KeeperException,
                                    InterruptedException,
                                    MerrittZKNodeInvalid,
                                    MerrittStateError

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

MerrittZKNodeInvalid

MerrittStateError

delete

public void delete(org.apache.zookeeper.ZooKeeper client)
            throws MerrittStateError,
                   MerrittZKNodeInvalid,
                   org.apache.zookeeper.KeeperException,
                   InterruptedException

Specified by:

delete in class QueueItem

Throws:

MerrittStateError

MerrittZKNodeInvalid

org.apache.zookeeper.KeeperException

InterruptedException

acquirePendingAssembly

public static Access acquirePendingAssembly(org.apache.zookeeper.ZooKeeper client,
                                            Access.Queues queueName)
                                     throws MerrittZKNodeInvalid,
                                            org.apache.zookeeper.KeeperException,
                                            InterruptedException

Throws:

MerrittZKNodeInvalid

org.apache.zookeeper.KeeperException

InterruptedException

initNodes

public static void initNodes(org.apache.zookeeper.ZooKeeper client)
                      throws org.apache.zookeeper.KeeperException,
                             InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

listJobs

public static List<Access> listJobs(org.apache.zookeeper.ZooKeeper client,
                                    Access.Queues queueName,
                                    AccessState state)
                             throws org.apache.zookeeper.KeeperException,
                                    InterruptedException,
                                    MerrittZKNodeInvalid

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

MerrittZKNodeInvalid