| Package | Description |
|---|---|
| de.zib.scalaris |
This package contains means to communicate with the erlang scalaris ring from Java.
|
| de.zib.scalaris.jmx |
| 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) |
|
void |
Transaction.commit() |
Commits the current transaction.
|
Connection |
ConnectionFactory.createConnection() |
Creates a connection to a scalaris erlang node specified by the given
parameters.
|
Connection |
ConnectionFactory.createConnection(ConnectionPolicy connectionPolicy) |
Creates a connection to a scalaris erlang node specified by the given
parameters.
|
Connection |
ConnectionFactory.createConnection(java.lang.String clientName) |
Creates a connection to a scalaris erlang node specified by the given
parameters.
|
Connection |
ConnectionFactory.createConnection(java.lang.String clientName,
boolean clientNameAppendUUID) |
Creates a connection to a scalaris erlang node specified by the given
parameters.
|
Connection |
ConnectionFactory.createConnection(java.lang.String clientName,
boolean clientNameAppendUUID,
ConnectionPolicy connectionPolicy) |
Creates a connection to a scalaris erlang node specified by the given
parameters.
|
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.
|
com.ericsson.otp.erlang.OtpErlangObject |
Connection.doRPC(java.lang.String mod,
java.lang.String fun,
com.ericsson.otp.erlang.OtpErlangList args) |
Sends the given RPC and waits for a result.
|
com.ericsson.otp.erlang.OtpErlangObject |
Connection.doRPC(java.lang.String mod,
java.lang.String fun,
com.ericsson.otp.erlang.OtpErlangObject[] args) |
Sends the given RPC and waits for a result.
|
Connection |
ConnectionPool.getConnection() |
Gets a connection from the pool.
|
Connection |
ConnectionPool.getConnection(long timeout) |
Tries to get a valid connection from the pool waiting at most
timeout milliseconds.
|
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 |
DeleteResult.hasDeletedAll(Connection conn) |
Checks whether the delete operation has successfully deleted all replicas
(replicas which did not exist are counted as successfully deleted as
well).
|
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.
|
void |
ScalarisVM.killVM() |
Kills the Scalaris VM of the current connection.
|
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. |
void |
Connection.sendRPC(java.lang.String mod,
java.lang.String fun,
com.ericsson.otp.erlang.OtpErlangList args) |
Sends the given RPC and returns immediately.
|
void |
Connection.sendRPC(java.lang.String mod,
java.lang.String fun,
com.ericsson.otp.erlang.OtpErlangObject[] args) |
Sends the given RPC and returns immediately.
|
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 |
ScalarisVM.shutdownVM() |
Tells the Scalaris VM of the current connection to shut down gracefully.
|
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 |
|---|---|
AbstractTransaction() |
Constructor, uses the default connection returned by
ConnectionFactory.createConnection(). |
Monitor(java.lang.String node) |
Creates a connection to the erlang VM of the given Scalaris node.
|
ReplicatedDHT() |
Constructor, uses the default connection returned by
ConnectionFactory.createConnection(). |
RoutingTable() |
Constructor, uses the default connection returned by
ConnectionFactory.createConnection(). |
Scalaris() |
Constructor, uses the default connection returned by
ConnectionFactory.createConnection(). |
ScalarisVM(PeerNode node) |
Creates a connection to the erlang VM of the given Scalaris node.
|
ScalarisVM(java.lang.String node) |
Creates a connection to the erlang VM of the given Scalaris node.
|
Transaction() |
Constructor, uses the default connection returned by
ConnectionFactory.createConnection(). |
TransactionSingleOp() |
Constructor, uses the default connection returned by
ConnectionFactory.createConnection(). |
| 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.
|
| Constructor | Description |
|---|---|
MonitorNode(java.lang.String node) |
Creates a connection to the erlang VM of the given Scalaris node.
|
MonitorService(java.lang.String node) |
Creates a connection to the erlang VM of the given Scalaris node.
|