- checkResult_failAbort(OtpErlangObject, boolean) - Static method in class de.zib.scalaris.CommonErlangObjects
-
Processes the
received_raw term from erlang and if it is a
{fail, abort, KeyList}, issues an
AbortException
.
- checkResult_failAbort(OtpErlangTuple, boolean) - Static method in class de.zib.scalaris.CommonErlangObjects
-
Processes the
received_raw term from erlang and if it is a
{fail, abort, KeyList}, issues an
AbortException
.
- close() - Method in class de.zib.scalaris.Connection
-
Closes the connection to the remote node.
- closeAll() - Method in class de.zib.scalaris.ConnectionPool
-
Closes all available pooled connections.
- closeAllBut(Collection<PeerNode>) - Method in class de.zib.scalaris.ConnectionPool
-
Closes all available pooled connections to any node not in the given
collection.
- closeConnection() - Method in class de.zib.scalaris.AbstractTransaction
-
Closes the transaction's connection to a scalaris node.
- closeConnection() - Method in class de.zib.scalaris.Monitor
-
Closes the transaction's connection to a scalaris node.
- closeConnection() - Method in class de.zib.scalaris.ReplicatedDHT
-
Closes the transaction's connection to a scalaris node.
- closeConnection() - Method in class de.zib.scalaris.Scalaris
-
Closes the transaction's connection to a scalaris node.
- closeConnection() - Method in class de.zib.scalaris.ScalarisVM
-
Closes the transaction's connection to a scalaris node.
- commit() - Method in class de.zib.scalaris.Transaction
-
Commits the current transaction.
- CommitOp - Class in de.zib.scalaris.operations
-
An operation committing a transaction.
- CommitOp() - Constructor for class de.zib.scalaris.operations.CommitOp
-
Constructor
- commitTupleAtom - Static variable in class de.zib.scalaris.CommonErlangObjects
-
- CommonErlangObjects - Class in de.zib.scalaris
-
Contains some often used objects as static objects as static members in
order to avoid re-creating them each time they are needed.
- CommonErlangObjects() - Constructor for class de.zib.scalaris.CommonErlangObjects
-
- compareTo(ErlangValue) - Method in class de.zib.scalaris.ErlangValue
-
Compares two erlang values by their string representation (expensive!).
- Connection - Class in de.zib.scalaris
-
- Connection(OtpSelf, PeerNode) - Constructor for class de.zib.scalaris.Connection
-
Creates a new connection using the given nodes and a default connection
policy.
- Connection(OtpSelf, ConnectionPolicy) - Constructor for class de.zib.scalaris.Connection
-
Creates a new connection between the a self node and one of the
remoteNodes, selected by the connectionPolicy.
- ConnectionException - Exception in de.zib.scalaris
-
Exception that is thrown if an operation on a scalaris ring fails
because the connection is not active, a communication error occurred, an
exit signal was received or the remote node sent a message containing an
invalid cookie.
- ConnectionException() - Constructor for exception de.zib.scalaris.ConnectionException
-
Creates the exception with no message.
- ConnectionException(String) - Constructor for exception de.zib.scalaris.ConnectionException
-
Creates the exception with the given message.
- ConnectionException(Throwable) - Constructor for exception de.zib.scalaris.ConnectionException
-
Creates an exception taking the message of the given throwable.
- ConnectionException(OtpErlangObject) - Constructor for exception de.zib.scalaris.ConnectionException
-
Creates an exception including the message of the given erlang object.
- ConnectionException(Throwable, OtpErlangObject) - Constructor for exception de.zib.scalaris.ConnectionException
-
Creates an exception taking the message of the given throwable.
- ConnectionFactory - Class in de.zib.scalaris
-
Provides means to create connections to scalaris nodes.
- ConnectionFactory() - Constructor for class de.zib.scalaris.ConnectionFactory
-
Constructor, sets the parameters to use for connections according to
values given in a scalaris.properties file and falls back to
default values if values don't exist.
- ConnectionFactory(Properties) - Constructor for class de.zib.scalaris.ConnectionFactory
-
Constructor, sets the parameters to use for connections according to
values given in the given
Properties
object and falls back to
default values if values don't exist.
- ConnectionPolicy - Class in de.zib.scalaris
-
Defines a policy on how to select a node to connect to from a set of
possible nodes and whether to automatically re-connect.
- ConnectionPolicy(PeerNode) - Constructor for class de.zib.scalaris.ConnectionPolicy
-
Creates a connection policy with one available node to connect to.
- ConnectionPolicy(List<PeerNode>) - Constructor for class de.zib.scalaris.ConnectionPolicy
-
Creates a connection policy with the given set of nodes available for
connections.
- ConnectionPool - Class in de.zib.scalaris
-
Implements a simple (thread-safe) connection pool for Scalaris connections.
- ConnectionPool(ConnectionFactory, int) - Constructor for class de.zib.scalaris.ConnectionPool
-
Creates a new connection pool.
- convert(int, ErlangValue) - Method in interface de.zib.scalaris.ErlangValue.ListElementConverter
-
Conversion function.
- convert(int, ErlangValue) - Method in class de.zib.scalaris.ErlangValue.StringListElementConverter
-
- convertToErlang(T) - Static method in class de.zib.scalaris.ErlangValue
-
- createConnection(String, boolean, ConnectionPolicy) - Method in class de.zib.scalaris.ConnectionFactory
-
Creates a connection to a scalaris erlang node specified by the given
parameters.
- createConnection(String, boolean) - Method in class de.zib.scalaris.ConnectionFactory
-
Creates a connection to a scalaris erlang node specified by the given
parameters.
- createConnection(String) - Method in class de.zib.scalaris.ConnectionFactory
-
Creates a connection to a scalaris erlang node specified by the given
parameters.
- createConnection(ConnectionPolicy) - Method in class de.zib.scalaris.ConnectionFactory
-
Creates a connection to a scalaris erlang node specified by the given
parameters.
- createConnection() - Method in class de.zib.scalaris.ConnectionFactory
-
Creates a connection to a scalaris erlang node specified by the given
parameters.