| Package | Description |
|---|---|
| de.zib.scalaris |
This package contains means to communicate with the erlang scalaris ring from Java.
|
| de.zib.scalaris.executor | |
| de.zib.scalaris.jmx | |
| de.zib.scalaris.operations |
| Modifier and Type | Method | Description |
|---|---|---|
void |
AbstractTransaction.addDelOnList(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangList toAdd,
com.ericsson.otp.erlang.OtpErlangList toRemove) |
Changes the list stored at the given key, i.e.
|
<T> void |
AbstractTransaction.addDelOnList(java.lang.String key,
java.util.List<T> toAdd,
java.util.List<T> toRemove) |
Changes the list stored at the given key, i.e.
|
void |
Transaction.addDelOnList(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangList toAdd,
com.ericsson.otp.erlang.OtpErlangList toRemove) |
|
<T> void |
Transaction.addDelOnList(java.lang.String key,
java.util.List<T> toAdd,
java.util.List<T> toRemove) |
|
ScalarisVM.AddNodesResult |
ScalarisVM.addNodes(int number) |
Adds the given number of nodes to the Scalaris VM of the current connection.
|
void |
AbstractTransaction.addOnNr(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangDouble toAdd) |
Changes the number stored at the given key, i.e.
|
void |
AbstractTransaction.addOnNr(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangLong toAdd) |
Changes the number stored at the given key, i.e.
|
<T> void |
AbstractTransaction.addOnNr(java.lang.String key,
T toAdd) |
Changes the number stored at the given key, i.e.
|
void |
Transaction.addOnNr(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangDouble toAdd) |
|
void |
Transaction.addOnNr(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangLong toAdd) |
|
<T> void |
Transaction.addOnNr(java.lang.String key,
T toAdd) |
|
static void |
CommonErlangObjects.checkResult_failAbort(com.ericsson.otp.erlang.OtpErlangObject received_raw,
boolean compressed) |
Processes the received_raw term from erlang and if it is a
{fail, abort, KeyList}, issues an
AbortException. |
static void |
CommonErlangObjects.checkResult_failAbort(com.ericsson.otp.erlang.OtpErlangTuple received,
boolean compressed) |
Processes the received_raw term from erlang and if it is a
{fail, abort, KeyList}, issues an
AbortException. |
void |
Transaction.commit() |
Commits the current transaction.
|
DeleteResult |
ReplicatedDHT.delete(com.ericsson.otp.erlang.OtpErlangString key) |
Tries to delete all replicas of the given key in 2000ms.
|
DeleteResult |
ReplicatedDHT.delete(com.ericsson.otp.erlang.OtpErlangString key,
int timeout) |
Tries to delete all replicas of the given key.
|
DeleteResult |
ReplicatedDHT.delete(java.lang.String key) |
Tries to delete all replicas of the given key in 2000ms.
|
DeleteResult |
ReplicatedDHT.delete(java.lang.String key,
int timeout) |
Tries to delete all replicas of the given key.
|
ScalarisVM.GetInfoResult |
ScalarisVM.getInfo() |
Gets some information about the VM and Scalaris.
|
Monitor.GetNodeInfoResult |
Monitor.getNodeInfo() |
Gets some information about the VM and Scalaris.
|
Monitor.GetNodePerformanceResult |
Monitor.getNodePerformance() |
Gets some information about the VM and Scalaris.
|
java.util.List<ErlangValue> |
ScalarisVM.getNodes() |
Gets the names of the nodes in the Scalaris VM of the current connection.
|
int |
ScalarisVM.getNumberOfNodes() |
Gets the number of nodes in the Scalaris VM of the current connection.
|
java.util.List<java.lang.String> |
ScalarisVM.getOtherVMs(int max) |
Retrieves additional nodes from the Scalaris VM of the current
connection for use by
ConnectionFactory.addNode(String). |
java.util.List<java.lang.String> |
Scalaris.getRandomNodes(int max) |
Retrieves random nodes from Scalaris for use by
ConnectionFactory.addNode(String) or ScalarisVM. |
int |
RoutingTable.getReplicationFactor() |
Returns the replication factor used by the current routing table
implementation.
|
Monitor.GetServiceInfoResult |
Monitor.getServiceInfo() |
Gets some information about the Scalaris ring.
|
Monitor.GetServicePerformanceResult |
Monitor.getServicePerformance() |
Gets some information about the Scalaris ring.
|
java.lang.String |
ScalarisVM.getVersion() |
Gets the version of the Scalaris VM of the current connection.
|
boolean |
ScalarisVM.killNode(ErlangValue name) |
Kills the given node inside the Scalaris VM of the current connection.
|
java.util.List<ErlangValue> |
ScalarisVM.killNodes(int number) |
Kills the given number of nodes inside the Scalaris VM of the current
connection.
|
ScalarisVM.DeleteNodesByNameResult |
ScalarisVM.killNodes(java.util.List<ErlangValue> names) |
Kills the given nodes inside the Scalaris VM of the current connection.
|
abstract void |
ResultList.processAddDelOnListAt(int pos) |
Processes the result at the given position which originated from
a add_del_on_list request.
|
void |
Transaction.ResultList.processAddDelOnListAt(int pos) |
Processes the result at the given position which originated from
a add_del_on_list request.
|
void |
TransactionSingleOp.ResultList.processAddDelOnListAt(int pos) |
Processes the result at the given position which originated from
a add_del_on_list request.
|
abstract void |
ResultList.processAddOnNrAt(int pos) |
Processes the result at the given position which originated from
an add_on_nr request.
|
void |
Transaction.ResultList.processAddOnNrAt(int pos) |
Processes the result at the given position which originated from
an add_on_nr request.
|
void |
TransactionSingleOp.ResultList.processAddOnNrAt(int pos) |
Processes the result at the given position which originated from
an add_on_nr request.
|
void |
Transaction.ResultList.processCommitAt(int pos) |
Processes the result at the given position which originated from
a commit request.
|
ErlangValue |
ResultList.processReadAt(int pos) |
Processes the result at the given position which originated from a read
request and returns the value that has been read.
|
abstract void |
ResultList.processTestAndSetAt(int pos) |
Processes the result at the given position which originated from
a test_and_set request.
|
void |
Transaction.ResultList.processTestAndSetAt(int pos) |
Processes the result at the given position which originated from
an add_on_nr request.
|
void |
TransactionSingleOp.ResultList.processTestAndSetAt(int pos) |
Processes the result at the given position which originated from
a test_and_set request.
|
abstract void |
ResultList.processWriteAt(int pos) |
Processes the result at the given position which originated from
a write request.
|
void |
Transaction.ResultList.processWriteAt(int pos) |
Processes the result at the given position which originated from
a write request.
|
void |
TransactionSingleOp.ResultList.processWriteAt(int pos) |
Processes the result at the given position which originated from
a write request.
|
ErlangValue |
AbstractTransaction.read(com.ericsson.otp.erlang.OtpErlangString key) |
Gets the value stored under the given
key. |
ErlangValue |
AbstractTransaction.read(java.lang.String key) |
Gets the value stored under the given
key. |
abstract ResL |
AbstractTransaction.req_list(ReqL req) |
Executes all requests in
req. |
Transaction.ResultList |
Transaction.req_list(TransactionOperation op) |
Executes the given operation.
|
Transaction.ResultList |
Transaction.req_list(Transaction.RequestList req) |
Executes all requests in
req. |
TransactionSingleOp.ResultList |
TransactionSingleOp.req_list(TransactionSingleOpOperation op) |
Executes the given operation.
|
TransactionSingleOp.ResultList |
TransactionSingleOp.req_list(TransactionSingleOp.RequestList req) |
Executes all requests in
req and commits each one of them in
a single transaction. |
boolean |
ScalarisVM.shutdownNode(ErlangValue name) |
Shuts down the given node (graceful leave) inside the Scalaris VM of the
current connection.
|
java.util.List<ErlangValue> |
ScalarisVM.shutdownNodes(int number) |
Shuts down the given number of nodes (graceful leave) inside the
Scalaris VM of the current connection.
|
ScalarisVM.DeleteNodesByNameResult |
ScalarisVM.shutdownNodesByName(java.util.List<ErlangValue> names) |
Shuts down the given nodes (graceful leave) inside the Scalaris VM of the
current connection.
|
void |
AbstractTransaction.testAndSet(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangObject oldValue,
com.ericsson.otp.erlang.OtpErlangObject newValue) |
Stores the given key/new_value pair if the old value at
key is old_value (atomic test_and_set).
|
<OldT,NewT> |
AbstractTransaction.testAndSet(java.lang.String key,
OldT oldValue,
NewT newValue) |
Stores the given key/new_value pair if the old value at
key is old_value (atomic test_and_set).
|
void |
Transaction.testAndSet(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangObject oldValue,
com.ericsson.otp.erlang.OtpErlangObject newValue) |
|
<OldT,NewT> |
Transaction.testAndSet(java.lang.String key,
OldT oldValue,
NewT newValue) |
|
void |
AbstractTransaction.write(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangObject value) |
Stores the given
key/value pair. |
<T> void |
AbstractTransaction.write(java.lang.String key,
T value) |
Stores the given
key/value pair. |
void |
Transaction.write(com.ericsson.otp.erlang.OtpErlangString key,
com.ericsson.otp.erlang.OtpErlangObject value) |
|
<T> void |
Transaction.write(java.lang.String key,
T value) |
| Constructor | Description |
|---|---|
DeleteResult(com.ericsson.otp.erlang.OtpErlangList list) |
Creates a delete state object by converting the result list returned from
erlang.
|
| Modifier and Type | Method | Description |
|---|---|---|
int |
ScalarisChangeListOp1.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests) |
|
int |
ScalarisChangeListOp2.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests) |
|
int |
ScalarisIncrementOp1.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests) |
|
int |
ScalarisIncrementOp2.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests) |
|
int |
ScalarisOp.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests) |
Executes the given phase.
|
int |
ScalarisReadOp.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests) |
|
int |
ScalarisWriteOp.doPhase(int phase,
int firstOp,
ResultList results,
RequestList requests) |
|
void |
ScalarisOpExecutor.run() |
Executes all operations previously added with
ScalarisOpExecutor.addOp(ScalarisOp). |
| Modifier and Type | Method | Description |
|---|---|---|
java.lang.Double |
MonitorNode.getCurLatencyAvg() |
|
java.lang.Double |
MonitorNodeMBean.getCurLatencyAvg() |
Gets the current, i.e.
|
java.lang.Double |
MonitorService.getCurLatencyAvg() |
|
java.lang.Double |
MonitorServiceMBean.getCurLatencyAvg() |
Gets the current, i.e.
|
java.lang.Double |
MonitorNode.getCurLatencyStddev() |
|
java.lang.Double |
MonitorNodeMBean.getCurLatencyStddev() |
Gets the current, i.e.
|
java.lang.Double |
MonitorService.getCurLatencyStddev() |
|
java.lang.Double |
MonitorServiceMBean.getCurLatencyStddev() |
Gets the current, i.e.
|
int |
MonitorNode.getDhtNodes() |
|
int |
MonitorNodeMBean.getDhtNodes() |
Gets the number of Scalaris nodes running in the VM the monitor is
connected to.
|
java.lang.String |
MonitorNode.getErlangVersion() |
|
java.lang.String |
MonitorNodeMBean.getErlangVersion() |
Gets the version of Erlang running in the VM the monitor is connected
to.
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorNode.getLatencyAvg() |
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorNodeMBean.getLatencyAvg() |
Gets average latency values collected in the VM the monitor is connected
to.
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorService.getLatencyAvg() |
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorServiceMBean.getLatencyAvg() |
Gets average latency values of the whole Scalaris ring from the VM the
monitor is connected to.
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorNode.getLatencyStddev() |
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorNodeMBean.getLatencyStddev() |
Gets the standard deviation of the latency values collected in the VM the
monitor is connected to.
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorService.getLatencyStddev() |
|
java.util.Map<java.lang.Long,java.lang.Double> |
MonitorServiceMBean.getLatencyStddev() |
Gets the standard deviation of the latency values of the whole Scalaris
ring from the VM the monitor is connected to.
|
java.lang.Long |
MonitorService.getNodes() |
|
java.lang.Long |
MonitorServiceMBean.getNodes() |
Gets the number of Scalaris nodes of the whole Scalaris ring from the VM
the monitor is connected to.
|
java.lang.String |
MonitorNode.getScalarisVersion() |
|
java.lang.String |
MonitorNodeMBean.getScalarisVersion() |
Gets the version of Scalaris running in the VM the monitor is connected
to.
|
java.lang.Long |
MonitorService.getTotalLoad() |
|
java.lang.Long |
MonitorServiceMBean.getTotalLoad() |
Gets the total load of the whole Scalaris ring from the VM the monitor is
connected to.
|
| Modifier and Type | Method | Description |
|---|---|---|
java.lang.Object |
AddDelOnListOp.processResult() |
|
java.lang.Object |
AddOnNrOp.processResult() |
|
java.lang.Object |
CommitOp.processResult() |
|
java.lang.Object |
Operation.processResult() |
Processes the result set by
Operation.setResult(OtpErlangObject, boolean). |
ErlangValue |
ReadOp.processResult() |
|
ReadRandomFromListOp.Result |
ReadRandomFromListOp.processResult() |
|
ReadSublistOp.Result |
ReadSublistOp.processResult() |
|
java.lang.Object |
TestAndSetOp.processResult() |
|
java.lang.Object |
WriteOp.processResult() |
|
static void |
CommitOp.processResult_commit(com.ericsson.otp.erlang.OtpErlangObject received_raw,
boolean compressed) |
Processes the received_raw term from erlang interpreting it as a
result from a commit operation.
|
java.lang.Object |
AddDelOnListOp.processResultSingle() |
|
java.lang.Object |
AddOnNrOp.processResultSingle() |
|
ErlangValue |
ReadOp.processResultSingle() |
|
ReadRandomFromListOp.Result |
ReadRandomFromListOp.processResultSingle() |
|
ReadSublistOp.Result |
ReadSublistOp.processResultSingle() |
|
java.lang.Object |
TestAndSetOp.processResultSingle() |
|
java.lang.Object |
TransactionSingleOpOperation.processResultSingle() |
Processes the result set by
Operation.setResult(OtpErlangObject, boolean)
assuming that operation was committed. |
java.lang.Object |
WriteOp.processResultSingle() |