A B C D E F G H I J K L M N O P Q R S T U V W 

A

abort(StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Ends a transaction after a failure.
AbstractCacheListener - Class in co.paralleluniverse.galaxy
An empty (no-op) implementation of CacheListener.
AbstractCacheListener() - Constructor for class co.paralleluniverse.galaxy.AbstractCacheListener
 
AbstractNodeAddressResolver<Address> - Class in co.paralleluniverse.galaxy.cluster
 
AbstractNodeAddressResolver(Cluster) - Constructor for class co.paralleluniverse.galaxy.cluster.AbstractNodeAddressResolver
 
addDependency(Service) - Method in class co.paralleluniverse.common.spring.Service
Adds a service this service depends on.
addLifecycleListener(LifecycleListener) - Method in interface co.paralleluniverse.galaxy.Cluster
Adds a listener for lifecycle events.
addListener(DistributedTree.Listener) - Method in class co.paralleluniverse.galaxy.cluster.DistributedBranchHelper
 
addListener(String, DistributedTree.Listener) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Adds a listener listening for modifications on the given node.
addListener(String, DistributedTree.Listener) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
addMasterNodePropertyListener(String, NodePropertyListener) - Method in interface co.paralleluniverse.galaxy.Cluster
Adds a listener that will be notified when a node property has changed on one of the master nodes.
addMessageListener(long, MessageListener) - Method in interface co.paralleluniverse.galaxy.Messenger
Adds a message listener on a lonng topic.
addMessageListener(String, MessageListener) - Method in interface co.paralleluniverse.galaxy.Messenger
Adds a message listener on a String topic.
addNodeChangeListener(NodeChangeListener) - Method in interface co.paralleluniverse.galaxy.Cluster
Adds a listener for events relating nodes joining and leaving the cluster.
addNodeProperty(String, boolean, boolean, ReaderWriter<?>) - Method in interface co.paralleluniverse.galaxy.Cluster
Adds a new node property that will be visible on the cluster.
addSlaveConfigurationListener(SlaveConfigurationListener) - Method in interface co.paralleluniverse.galaxy.Cluster
Adds a listener for events relating to this master-slaves node group configuration.
addSlaveNodePropertyListener(String, NodePropertyListener) - Method in interface co.paralleluniverse.galaxy.Cluster
Adds a listener that will be notified when a node property has changed on one of this node's slaves.
afterPropertiesSet() - Method in class co.paralleluniverse.common.spring.Component
 
alloc(int, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Allocates one or more new (and empty) items in the store.
allocAsync(int, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Allocates one or more new (and empty) items in the store.
asObjectInput(Input, Kryo) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil
 
asObjectOutput(Output, Kryo) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil
 
assertDuringInitialization() - Method in class co.paralleluniverse.common.spring.Component
 
assertInitialized() - Method in class co.paralleluniverse.common.spring.Component
 
available(boolean) - Method in class co.paralleluniverse.common.spring.Service
Called when this service becomes available (it is ready and all its dependencies are available) or unavailable.
awaitAvailable() - Method in class co.paralleluniverse.common.spring.Service
Availability changes between calls to this method are the responsibility of the user code, which must be able to handle a short interruption (e.g.

B

beginTransaction() - Method in interface co.paralleluniverse.galaxy.Store
Creates a new transaction.
BOOLEAN - Static variable in class co.paralleluniverse.galaxy.cluster.ReaderWriters
 
ByteArraySerializer - Interface in co.paralleluniverse.io.serialization
 
ByteBufferUtil - Class in co.paralleluniverse.common.io
 

C

Cache - Interface in co.paralleluniverse.galaxy
 
CacheListener - Interface in co.paralleluniverse.galaxy
A listener for local cache events.
calcUtfLength(String) - Static method in class co.paralleluniverse.common.io.Streamables
Returns the length in bytes of a string's UTF-8 encoding.
cancel(boolean) - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
child(String) - Static method in class co.paralleluniverse.galaxy.cluster.DistributedTreeUtil
Returns the last component of a node's full path (i.e.
childExecutors - Variable in class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
Cluster - Interface in co.paralleluniverse.galaxy
The cluster management service.
cluster() - Method in class co.paralleluniverse.galaxy.Grid
Returns the grid's cluster management and node lifecycle service.
co.paralleluniverse.common.concurrent - package co.paralleluniverse.common.concurrent
 
co.paralleluniverse.common.io - package co.paralleluniverse.common.io
 
co.paralleluniverse.common.spring - package co.paralleluniverse.common.spring
 
co.paralleluniverse.galaxy - package co.paralleluniverse.galaxy
 
co.paralleluniverse.galaxy.cluster - package co.paralleluniverse.galaxy.cluster
 
co.paralleluniverse.galaxy.testing - package co.paralleluniverse.galaxy.testing
 
co.paralleluniverse.io.serialization - package co.paralleluniverse.io.serialization
 
co.paralleluniverse.io.serialization.kryo - package co.paralleluniverse.io.serialization.kryo
 
commit(StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Ends a transaction, and makes all updates visible by all other nodes in the cluster.
Component - Class in co.paralleluniverse.common.spring
An object instance initialized by the Spring container.
Component(String) - Constructor for class co.paralleluniverse.common.spring.Component
Constructs a component with a given name.
contains(long) - Method in class co.paralleluniverse.galaxy.StoreTransaction
Tests whether a given item participates in this transaction.
copyOf(ByteBuffer) - Static method in class co.paralleluniverse.common.io.Persistables
Returns a newly-allocated copy of a given ByteBuffer's remaining contents.
correctForRoot(String) - Static method in class co.paralleluniverse.galaxy.cluster.DistributedTreeUtil
Returns the full path of the given node, but if it's the root, returns the empty string.
create(String, boolean) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Creates a new node in the tree.
create(String, boolean) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
createEphemeralOrdered(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Creates an ephemeral node that, when returned by getChildren(), will be placed in the list in relation to other ordered ephemeral nodes by the relative order of its creation.
createEphemeralOrdered(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
createTopic() - Method in interface co.paralleluniverse.galaxy.Messenger
Returns a new topic.
CurrentThreadExecutor - Class in co.paralleluniverse.common.concurrent
 

D

del(long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Deletes an item from the store.
delAsync(long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
 
delete(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Deletes a node and all its descendents from the tree.
delete(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
deleteDir(String) - Static method in class co.paralleluniverse.galaxy.testing.GalaxyTestingUtils
 
destroy() - Method in class co.paralleluniverse.common.spring.Component
 
DistributedBranchHelper - Class in co.paralleluniverse.galaxy.cluster
Helps deal with a branch of a distributed tree, when we want to consider the nodes only when they have given sub-nodes ("required properties").
DistributedBranchHelper(DistributedTree, String, boolean) - Constructor for class co.paralleluniverse.galaxy.cluster.DistributedBranchHelper
 
DistributedTree - Interface in co.paralleluniverse.galaxy.cluster
Provides access to a distributed, observable filesystem-like node tree for configuration data.
DistributedTree.Listener - Interface in co.paralleluniverse.galaxy.cluster
A listener for DistributedTree node events.
DistributedTree.ListenerAdapter - Class in co.paralleluniverse.galaxy.cluster
An abstract adapter class for receiving DistributedTree events.
DistributedTree.ListenerAdapter() - Constructor for class co.paralleluniverse.galaxy.cluster.DistributedTree.ListenerAdapter
 
DistributedTreeAdapter - Class in co.paralleluniverse.galaxy.cluster
 
DistributedTreeAdapter(DistributedTree) - Constructor for class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
DistributedTreeUtil - Class in co.paralleluniverse.galaxy.cluster
Some utility functions for working with a DistributedTree.
done() - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
done(V) - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 

E

evicted(Cache, long) - Method in class co.paralleluniverse.galaxy.AbstractCacheListener
 
evicted(Cache, long) - Method in interface co.paralleluniverse.galaxy.CacheListener
The data item has been evicted from the local cache.
execute(Runnable) - Method in class co.paralleluniverse.common.concurrent.CurrentThreadExecutor
 
execute(Runnable) - Method in class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
exists(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Returns true if the given node exists in the tree.
exists(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
ExternalizableKryoSerializer<T extends Externalizable> - Class in co.paralleluniverse.io.serialization.kryo
 
ExternalizableKryoSerializer() - Constructor for class co.paralleluniverse.io.serialization.kryo.ExternalizableKryoSerializer
 

F

failed(Throwable) - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
flush() - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Ensures that all updates to the tree done by this cluster node will have been seen by all nodes in the cluster when this method returns.
flush() - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
fromByteArray(Streamable, byte[]) - Static method in class co.paralleluniverse.common.io.Streamables
Reads a Streamable's serialized contents from a byte array.
fromByteArray(Streamable, byte[], int) - Static method in class co.paralleluniverse.common.io.Streamables
Reads a Streamable's serialized contents from a byte array.
fromByteArray(Streamable, byte[], int, int) - Static method in class co.paralleluniverse.common.io.Streamables
Reads a Streamable's serialized contents from a byte array.
fromByteArray(byte[]) - Method in class co.paralleluniverse.common.io.Streamables
 

G

GalaxyTestingUtils - Class in co.paralleluniverse.galaxy.testing
 
GalaxyTestingUtils() - Constructor for class co.paralleluniverse.galaxy.testing.GalaxyTestingUtils
 
get() - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
get(long, TimeUnit) - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
get(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Returns the contents of a given node.
get(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
get(String) - Method in interface co.paralleluniverse.galaxy.cluster.NodeInfo
Returns a given property of the node.
get(long) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item.
get(long, Persistable) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item into a Persistable.
get(long, short) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item, using a hint as to its owner in the cluster.
If the item is indeed found on the hinted node, the retrieval performance might be superior.
get(long, short, Persistable) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item into a Persistable, using a hint as to its owner in the cluster.
If the item is indeed found on the hinted node, the retrieval performance might be superior.
getAddress(NodeInfo) - Method in class co.paralleluniverse.galaxy.cluster.AbstractNodeAddressResolver
 
getAddress(String) - Method in interface co.paralleluniverse.galaxy.cluster.SlaveAddressResolver
 
getArray(ByteBuffer, int, Object) - Static method in class co.paralleluniverse.common.io.ByteBufferUtil
 
getArray(ByteBuffer, Object) - Static method in class co.paralleluniverse.common.io.ByteBufferUtil
 
getAsync(long) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously.
getAsync(long, Persistable) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item into a Persistable asynchronously.
getAsync(long, short) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously, using a hint as to its owner in the cluster.
getAsync(long, short, Persistable) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously into a Persistable, using a hint as to its owner in the cluster.
getChecksum() - Method in class co.paralleluniverse.common.io.HashFunctionChecksum
 
getChildExecutor(Runnable) - Method in class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
getChildExecutorKey(Runnable) - Method in class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
getChildren() - Method in class co.paralleluniverse.galaxy.cluster.DistributedBranchHelper
 
getChildren(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Returns all child-nodes (direct descendents) of a given node, with ephemeral ordered nodes returned in the order they were created.
getChildren(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
getDependedBy() - Method in class co.paralleluniverse.common.spring.Service
 
getDependencyGraph() - Method in class co.paralleluniverse.common.spring.Service
 
getDependsOn() - Method in class co.paralleluniverse.common.spring.Service
 
getDistributedTree() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns the DistributedTree used by the cluster.
getExecutor() - Method in interface co.paralleluniverse.common.concurrent.WithExecutor
Returns the executor on which to run the object's methods.
getForRead() - Method in interface co.paralleluniverse.galaxy.LineFunction.LineAccess
 
getForWrite(int) - Method in interface co.paralleluniverse.galaxy.LineFunction.LineAccess
 
getFromOwner(long, long) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item, using a hint as to its owner in the cluster.
getFromOwner(long, long, Persistable) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item, using a hint as to its owner in the cluster.
getFromOwnerAsync(long, long) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously, using a hint as to its owner in the cluster.
getFromOwnerAsync(long, long, Persistable) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously, using a hint as to its owner in the cluster.
getInstance(int) - Static method in class co.paralleluniverse.common.concurrent.QueueFactory
 
getInstance() - Static method in class co.paralleluniverse.galaxy.Grid
Retrieves the named grid instance, as specified in the default configuration file.
getInstance(String, String) - Static method in class co.paralleluniverse.galaxy.Grid
Retrieves the grid instance, as defined in the given configuration file.
getInstance(String, Properties) - Static method in class co.paralleluniverse.galaxy.Grid
Retrieves the grid instance, as defined in the given configuration file.
getInstance() - Static method in class co.paralleluniverse.io.serialization.Serialization
 
getKryo() - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
getKryo() - Static method in class co.paralleluniverse.io.serialization.Serialization
 
getListener(long) - Method in interface co.paralleluniverse.galaxy.Cache
 
getListener(long) - Method in interface co.paralleluniverse.galaxy.Store
 
getMaster(short) - Method in interface co.paralleluniverse.galaxy.Cluster
Returns a given node-group master if this node is a slave.
getMasters() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns all the current, online master nodes.
getMaxItemSize() - Method in interface co.paralleluniverse.galaxy.Store
Returns the maximum size, in bytes, of a data item in the grid.
getMyMaster() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns this node's master node if this is a slave.
getMyNodeId() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns this cluster node's ID.
getMyNodeInfo() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns this cluster node's info.
getMySlaves() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns this node's master node if this is a slave.
getName() - Method in class co.paralleluniverse.common.spring.Component
 
getName() - Method in interface co.paralleluniverse.galaxy.cluster.NodeInfo
Returns the node's cluster-wide unique name.
getNode(Address) - Method in interface co.paralleluniverse.galaxy.cluster.SlaveAddressResolver
 
getNodeAddress(short) - Method in class co.paralleluniverse.galaxy.cluster.AbstractNodeAddressResolver
 
getNodeAddress(short) - Method in interface co.paralleluniverse.galaxy.cluster.NodeAddressResolver
Returns the address of the master node with the given ID.
getNodeId(Address) - Method in class co.paralleluniverse.galaxy.cluster.AbstractNodeAddressResolver
 
getNodeId(Address) - Method in interface co.paralleluniverse.galaxy.cluster.NodeAddressResolver
 
getNodeId() - Method in interface co.paralleluniverse.galaxy.cluster.NodeInfo
Returns the node's ID.
getNodeInfoByName(String) - Method in interface co.paralleluniverse.galaxy.Cluster
Returns a NodeInfo for any cluster node, identified by its (unique) name.
getNodes() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns the IDs of all online nodes (each master and slaves group of nodes is listed once - remember: masters and slaves share the same ID).
getNodesByProperty(String, Object) - Method in interface co.paralleluniverse.galaxy.Cluster
Returns a set of NodeInfo for any cluster node, with a property equal to the given value.
getObject() - Method in class co.paralleluniverse.common.spring.NullBean
 
getObjectType() - Method in class co.paralleluniverse.common.spring.NullBean
 
getProperties() - Method in interface co.paralleluniverse.galaxy.cluster.NodeInfo
Returns a collection of all of this node's property names.
getRoot(String, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gets or possibly creates a root data item.
getRoot(String, long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gets or possibly creates a root data item.
gets(long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item, and pins the shared (cached) instance to this node.
gets(long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item into a Persistable, and pins the shared (cached) instance to this node.
gets(long, short, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
gets(long, short, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item into a Persistable with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
getsAsync(long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously, and pins the shared (cached) instance to this node.
getsAsync(long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data asynchronously item into a Persistable, and pins the shared (cached) instance to this node.
getsAsync(long, short, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
getsAsync(long, short, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data asynchronously item into a Persistable with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
getsFromOwner(long, long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
getsFromOwner(long, long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
getsFromOwnerAsync(long, long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
getsFromOwnerAsync(long, long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously with a hint as to its owner in the cluster, and pins the shared (cached) instance to this node.
getState(long) - Method in interface co.paralleluniverse.galaxy.Store
Returns an item's state in the local store.
getType() - Method in class co.paralleluniverse.common.spring.Component
 
getUnderlyingResource() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns the main resource used by the cluster for coordination, namely a org.jgroups.JChannel for a JGroups-based cluster or a com.netflix.curator.framework.CuratorFramework for a ZooKeeper-based cluster.
getVersion(long) - Method in interface co.paralleluniverse.galaxy.Store
CacheLine version
getx(long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item, makes this node its exclusive owner, and pins it.
getx(long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item into a Persistable, makes this node its exclusive owner, and pins it.
getx(long, short, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
getx(long, short, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
getxAsync(long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously, makes this node its exclusive owner, and pins it.
getxAsync(long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously into a Persistable, makes this node its exclusive owner, and pins it.
getxAsync(long, short, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
getxAsync(long, short, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
getxFromOwner(long, long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
getxFromOwner(long, long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
getxFromOwnerAsync(long, long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
getxFromOwnerAsync(long, long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Retrieves a given data item asynchronously with a hint as to its owner in the cluster, makes this node its exclusive owner, and pins it.
goOffline() - Method in interface co.paralleluniverse.galaxy.Cluster
Leave the cluster and shutdown the JVM.
goOnline() - Method in class co.paralleluniverse.galaxy.Grid
Makes this node a full participant in the cluster (rather than just an observer).
Grid - Class in co.paralleluniverse.galaxy
The central access point to the grid's services (the word grid describes the collection distributed of software provided in the physical node cluster).

H

HashFunctionChecksum - Class in co.paralleluniverse.common.io
 
HashFunctionChecksum(HashFunction) - Constructor for class co.paralleluniverse.common.io.HashFunctionChecksum
 
hasServer() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns true if the grid is configured to use a server.

I

init() - Method in class co.paralleluniverse.common.spring.Component
Called after bean properties have been set.
init() - Method in class co.paralleluniverse.common.spring.Service
 
init() - Method in class co.paralleluniverse.galaxy.cluster.AbstractNodeAddressResolver
 
init() - Method in class co.paralleluniverse.galaxy.cluster.DistributedBranchHelper
 
instance - Static variable in class co.paralleluniverse.common.concurrent.CurrentThreadExecutor
 
INTEGER - Static variable in class co.paralleluniverse.galaxy.cluster.ReaderWriters
 
invalidated(Cache, long) - Method in class co.paralleluniverse.galaxy.AbstractCacheListener
 
invalidated(Cache, long) - Method in interface co.paralleluniverse.galaxy.CacheListener
The data item has been invalidated - probably requested exclusively by another node, or, possibly, deleted.
invoke(LineFunction.LineAccess) - Method in interface co.paralleluniverse.galaxy.LineFunction
 
invoke(long, LineFunction<T>) - Method in interface co.paralleluniverse.galaxy.Store
 
invokeAsync(long, LineFunction<T>) - Method in interface co.paralleluniverse.galaxy.Store
 
IOStreamSerializer - Interface in co.paralleluniverse.io.serialization
 
isAvailable() - Method in class co.paralleluniverse.common.spring.Service
 
isCancelled() - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
isDone() - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
isInitialized() - Method in class co.paralleluniverse.common.spring.Component
 
isLessThan(ItemState) - Method in enum co.paralleluniverse.galaxy.ItemState
 
isMaster() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns true if this node is a master; false if it's a slave.
isMaster(NodeInfo) - Method in interface co.paralleluniverse.galaxy.Cluster
Returns true if the given node is a master; false if it's a slave.
isNodeComplete(String, Set<String>) - Method in class co.paralleluniverse.galaxy.cluster.DistributedBranchHelper
 
isOnline() - Method in interface co.paralleluniverse.galaxy.Cluster
Returns true if this node is online (operational and visible to other nodes).
isPinned(long) - Method in interface co.paralleluniverse.galaxy.Store
Tests whether an item is pinned on this node.
isReady() - Method in class co.paralleluniverse.common.spring.Service
 
isRootCreated(long, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Tests whether a root item has been newly created.
isSingleton() - Method in class co.paralleluniverse.common.spring.NullBean
 
ItemState - Enum in co.paralleluniverse.galaxy
Represents the state of an item in the Galaxy local store.
iterate(String) - Static method in class co.paralleluniverse.galaxy.cluster.DistributedTreeUtil
Returns an Iterable over a node's path components.
iterator() - Method in class co.paralleluniverse.galaxy.StoreTransaction
Returns an iterator over all item IDs participating in the transaction.

J

JDKSerializer - Class in co.paralleluniverse.io.serialization
 
JDKSerializer() - Constructor for class co.paralleluniverse.io.serialization.JDKSerializer
 
joinedCluster() - Method in interface co.paralleluniverse.galaxy.cluster.LifecycleListener
Invoked when this node has joined the cluster, but before it has gone online.

K

killed(Cache, long) - Method in class co.paralleluniverse.galaxy.AbstractCacheListener
 
killed(Cache, long) - Method in interface co.paralleluniverse.galaxy.CacheListener
The data item belonged to a node that has died (without slave replacement)
kryo - Variable in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
KryoSerializer - Class in co.paralleluniverse.io.serialization.kryo
This class is not thread-safe.
KryoSerializer() - Constructor for class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
KryoUtil - Class in co.paralleluniverse.io.serialization.kryo
 

L

LifecycleListener - Interface in co.paralleluniverse.galaxy.cluster
A listener for lifecycle events.
LineFunction<T> - Interface in co.paralleluniverse.galaxy
 
LineFunction.LineAccess - Interface in co.paralleluniverse.galaxy
 
LONG - Static variable in class co.paralleluniverse.galaxy.cluster.ReaderWriters
 

M

main(String[]) - Static method in class co.paralleluniverse.galaxy.Server
Runs the Galaxy server.
MessageListener - Interface in co.paralleluniverse.galaxy
A listener for messages sent in the grid.
messageReceived(byte[]) - Method in class co.paralleluniverse.galaxy.AbstractCacheListener
 
messageReceived(byte[]) - Method in interface co.paralleluniverse.galaxy.CacheListener
Called when a message has been received.
messageReceived(short, byte[]) - Method in interface co.paralleluniverse.galaxy.MessageListener
Called when a message has been received.
messenger() - Method in class co.paralleluniverse.galaxy.Grid
Returns the grid's messaging service.
Messenger - Interface in co.paralleluniverse.galaxy
The grid's messaging service.

N

newDefaultSerializer(Class) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
newInstance() - Static method in class co.paralleluniverse.io.serialization.Serialization
 
newKryo() - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil
 
newMaster(NodeInfo) - Method in interface co.paralleluniverse.galaxy.cluster.SlaveConfigurationListener
Invoked when this (slave) node has got a new master.
nodeAdded(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree.Listener
Invoked when a new node has been added to the tree.
nodeAdded(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTree.ListenerAdapter
 
nodeAdded(short) - Method in interface co.paralleluniverse.galaxy.cluster.NodeChangeListener
Invoked when a new node (group) has joined the cluster.
NodeAddressResolver<Address> - Interface in co.paralleluniverse.galaxy.cluster
 
NodeChangeListener - Interface in co.paralleluniverse.galaxy.cluster
A a listener for events relating nodes joining and leaving the cluster.
nodeChildAdded(String, String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree.Listener
Invoked when a new child node of the listener's target node has been created.
nodeChildAdded(String, String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTree.ListenerAdapter
 
nodeChildDeleted(String, String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree.Listener
Invoked when a child node of the listener's target node has been deleted.
nodeChildDeleted(String, String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTree.ListenerAdapter
 
nodeChildUpdated(String, String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree.Listener
Invoked when a child node's contents of the listener's target node has been modified.
nodeChildUpdated(String, String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTree.ListenerAdapter
 
nodeDeleted(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree.Listener
Invoked when a node has been deleted from the tree.
nodeDeleted(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTree.ListenerAdapter
 
NodeInfo - Interface in co.paralleluniverse.galaxy.cluster
Provides information about a cluster node.
NodePropertyListener - Interface in co.paralleluniverse.galaxy.cluster
A listener for node-property change events.
nodeRemoved(short) - Method in interface co.paralleluniverse.galaxy.cluster.NodeChangeListener
Invoked when a node (group) has left the cluster.
nodeSwitched(short) - Method in interface co.paralleluniverse.galaxy.cluster.NodeChangeListener
Invoked when a node group's master has changed.
nodeUpdated(String) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree.Listener
Invoked when a node's contents has been modified.
nodeUpdated(String) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTree.ListenerAdapter
 
NullBean - Class in co.paralleluniverse.common.spring
 
NullBean() - Constructor for class co.paralleluniverse.common.spring.NullBean
 

O

offline() - Method in interface co.paralleluniverse.galaxy.cluster.LifecycleListener
Invoked when this node is taken offline, i.e.
online(boolean) - Method in interface co.paralleluniverse.galaxy.cluster.LifecycleListener
Invoked when this node is online, i.e.
OrderedThreadPoolExecutor - Class in co.paralleluniverse.common.concurrent
Adapted from Netty's org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor
OrderedThreadPoolExecutor(int, int, long, TimeUnit, int, ThreadFactory, RejectedExecutionHandler) - Constructor for class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
OrderedThreadPoolExecutor(int, int, long, TimeUnit, int, RejectedExecutionHandler) - Constructor for class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
OrderedThreadPoolExecutor(int, int, long, TimeUnit, int, ThreadFactory) - Constructor for class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
OrderedThreadPoolExecutor(int, int, long, TimeUnit, int) - Constructor for class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 

P

parent(String) - Static method in class co.paralleluniverse.galaxy.cluster.DistributedTreeUtil
Returns the parent tree node of a given node.
pathToResource(String) - Static method in class co.paralleluniverse.galaxy.testing.GalaxyTestingUtils
 
Persistable - Interface in co.paralleluniverse.common.io
This interface marks an object that can be persisted to a ByteBuffer.
persistable(Streamable) - Static method in class co.paralleluniverse.common.io.Persistables
Converts a Streamable into a Persistable.
persistable(ByteBuffer) - Static method in class co.paralleluniverse.common.io.Persistables
Converts a ByteBuffer into a Persistable.
Persistables - Class in co.paralleluniverse.common.io
Provides utility methods for working with Persistables and/or ByteBuffers.
postInit() - Method in class co.paralleluniverse.common.spring.Component
Called after bean properties have been set, and init() called.
postInit() - Method in class co.paralleluniverse.common.spring.Service
 
print(String, PrintStream) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Prints the tree's structure, starting at a given node, to the given stream.
print(String, PrintStream) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
propertyChanged(NodeInfo, String, Object) - Method in interface co.paralleluniverse.galaxy.cluster.NodePropertyListener
Invoked when the node's property has been added, changed or removed.
push(long, short...) - Method in interface co.paralleluniverse.galaxy.Store
Makes the given item available in the given nodes' cache.
pushx(long, short) - Method in interface co.paralleluniverse.galaxy.Store
Makes the given item available in the given node's cache, and makes that node the owner of the item.
put(byte[], StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Puts a new item into the store and returns its (newly allocated) ID.
put(ByteBuffer, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Puts a new item into the store and returns its (newly allocated) ID.
put(Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Puts a new item into the store and returns its (newly allocated) ID.
putArray(ByteBuffer, int, Object) - Static method in class co.paralleluniverse.common.io.ByteBufferUtil
 
putArray(ByteBuffer, Object) - Static method in class co.paralleluniverse.common.io.ByteBufferUtil
 
putAsync(byte[], StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Puts a new item into the store and returns its (newly allocated) ID.
putAsync(ByteBuffer, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Puts a new item into the store and returns its (newly allocated) ID.
putAsync(Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Puts a new item into the store and returns its (newly allocated) ID.

Q

QueueFactory - Class in co.paralleluniverse.common.concurrent
 

R

read(ByteBuffer) - Method in interface co.paralleluniverse.common.io.Persistable
Reads the object from the given ByteBuffer.
Upon return from this method, the buffer's position will have advanced past the read data.
read(DataInput) - Method in interface co.paralleluniverse.common.io.Streamable
Reads the object's contents from the given DataInput.
read(DataInput) - Method in class co.paralleluniverse.common.io.Streamables
 
read(long, ByteBuffer) - Method in interface co.paralleluniverse.common.io.VersionedPersistable
Reads the object from the given ByteBuffer.
Upon return from this method, the buffer's position will have advanced past the read data.
read(byte[]) - Method in interface co.paralleluniverse.galaxy.cluster.ReaderWriter
 
read(byte[]) - Method in interface co.paralleluniverse.io.serialization.ByteArraySerializer
 
read(byte[], int) - Method in interface co.paralleluniverse.io.serialization.ByteArraySerializer
 
read(InputStream) - Method in interface co.paralleluniverse.io.serialization.IOStreamSerializer
 
read(byte[]) - Method in class co.paralleluniverse.io.serialization.JDKSerializer
 
read(byte[], int) - Method in class co.paralleluniverse.io.serialization.JDKSerializer
 
read(InputStream) - Method in class co.paralleluniverse.io.serialization.JDKSerializer
 
read(Kryo, Input, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.ExternalizableKryoSerializer
 
read(byte[]) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
read(byte[], int) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
read(byte[], Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
read(byte[], int, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
read(InputStream) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
read(InputStream, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
read(byte[]) - Method in class co.paralleluniverse.io.serialization.Serialization
 
read(byte[], int) - Method in class co.paralleluniverse.io.serialization.Serialization
 
read(InputStream) - Method in class co.paralleluniverse.io.serialization.Serialization
 
readClassAndObject(Input) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
ReaderWriter<T> - Interface in co.paralleluniverse.galaxy.cluster
Reads and writes values from/to the cluster configuration.
ReaderWriters - Class in co.paralleluniverse.galaxy.cluster
Some ReaderWriters for common types.
readObject(Input, Class<T>, Serializer) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
readObject(Input, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
readObjectOrNull(Input, Class<T>) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
readObjectOrNull(Input, Class<T>, Serializer) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
received(Cache, long, long, ByteBuffer) - Method in class co.paralleluniverse.galaxy.AbstractCacheListener
 
received(Cache, long, long, ByteBuffer) - Method in interface co.paralleluniverse.galaxy.CacheListener
The data item has been updated by another node.
RefNotFoundException - Exception in co.paralleluniverse.galaxy
Thrown when an item ref was not found in the grid.
RefNotFoundException(long) - Constructor for exception co.paralleluniverse.galaxy.RefNotFoundException
 
register(byte, Class<T>) - Method in class co.paralleluniverse.common.io.Streamables
 
register(Class) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
register(Class, int) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
register(Class, Serializer) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
register(Class, Serializer, int) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
registerCommonClasses(Kryo) - Static method in class co.paralleluniverse.io.serialization.kryo.KryoUtil
 
registerWriteReplace(Class<?>, WriteReplace) - Method in class co.paralleluniverse.io.serialization.JDKSerializer
 
release(long) - Method in interface co.paralleluniverse.galaxy.Store
Releases a line that's been pinned to this node by one of the gets, getx, put operations.
removeChildExecutor(Object) - Method in class co.paralleluniverse.common.concurrent.OrderedThreadPoolExecutor
 
removeDependency(Service) - Method in class co.paralleluniverse.common.spring.Service
Removes a dependency.
removeLifecycleListener(LifecycleListener) - Method in interface co.paralleluniverse.galaxy.Cluster
removeListener(DistributedTree.Listener) - Method in class co.paralleluniverse.galaxy.cluster.DistributedBranchHelper
 
removeListener(String, DistributedTree.Listener) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Removes a listener.
removeListener(String, DistributedTree.Listener) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
removeMasterNodePropertyListener(String, NodePropertyListener) - Method in interface co.paralleluniverse.galaxy.Cluster
Removes a NodePropertyListener listening on master nodes.
removeMessageListener(long, MessageListener) - Method in interface co.paralleluniverse.galaxy.Messenger
Removes a message listener from a lonng topic.
removeMessageListener(String, MessageListener) - Method in interface co.paralleluniverse.galaxy.Messenger
Removes a message listener from a String topic.
removeNodeChangeListener(NodeChangeListener) - Method in interface co.paralleluniverse.galaxy.Cluster
removeSlaveConfigurationListener(SlaveConfigurationListener) - Method in interface co.paralleluniverse.galaxy.Cluster
removeSlaveNodePropertyListener(String, NodePropertyListener) - Method in interface co.paralleluniverse.galaxy.Cluster
Removes a NodePropertyListener listening on this node's slaves.
ReplaceableObjectKryo - Class in co.paralleluniverse.io.serialization.kryo
A subclass of Kryo that respects java.io.Serializable's writeReplace and readResolve.
ReplaceableObjectKryo() - Constructor for class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
reset() - Method in class co.paralleluniverse.common.io.HashFunctionChecksum
 
rollback(StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Reverts set operations that were performed during the transactions.

S

send(short, String, byte[]) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a known node, on a String topic.
send(short, long, Streamable) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a known node, on a long topic.
send(short, String, Streamable) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a known node, on a String topic.
send(short, long, byte[]) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a known node, on a long topic.
send(long, Streamable) - Method in interface co.paralleluniverse.galaxy.Store
Sends a message to an item, which will be received by CacheListener.messageReceived on the item's owning node.
send(long, byte[]) - Method in interface co.paralleluniverse.galaxy.Store
Sends a message to an item, which will be received by CacheListener.messageReceived on the item's owning node.
sendAsync(long, Streamable) - Method in interface co.paralleluniverse.galaxy.Store
Sends a message to an item, which will be received by CacheListener.messageReceived on the item's owning node.
sendAsync(long, byte[]) - Method in interface co.paralleluniverse.galaxy.Store
Sends a message to an item, which will be received by CacheListener.messageReceived on the item's owning node.
sendToOwnerOf(long, long, byte[]) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a long topic.
sendToOwnerOf(long, String, byte[]) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a String topic.
sendToOwnerOf(long, long, Streamable) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a long topic.
sendToOwnerOf(long, String, Streamable) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a String topic.
sendToOwnerOfAsync(long, long, byte[]) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a long topic.
sendToOwnerOfAsync(long, String, byte[]) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a String topic.
sendToOwnerOfAsync(long, long, Streamable) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a long topic.
sendToOwnerOfAsync(long, String, Streamable) - Method in interface co.paralleluniverse.galaxy.Messenger
Sends a message to a the owner of a known grid object node, on a String topic.
Serialization - Class in co.paralleluniverse.io.serialization
 
Server - Class in co.paralleluniverse.galaxy
This class runs the Galaxy server.
Server() - Constructor for class co.paralleluniverse.galaxy.Server
 
Service - Class in co.paralleluniverse.common.spring
A component that may have dependencies, and can signal its readiness to its dependents.
Service(String) - Constructor for class co.paralleluniverse.common.spring.Service
Constructs a service with a given name.
set(String, byte[]) - Method in interface co.paralleluniverse.galaxy.cluster.DistributedTree
Associates data with (sets the contents of) a given node.
set(String, byte[]) - Method in class co.paralleluniverse.galaxy.cluster.DistributedTreeAdapter
 
set(long, byte[], StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gains ownership of an item and sets its contents.
set(long, ByteBuffer, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gains ownership of an item and sets its contents.
set(long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gains ownership of an item and sets its contents.
setAsync(long, byte[], StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gains ownership of an item and sets its contents asynchronously.
setAsync(long, ByteBuffer, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gains ownership of an item and sets its contents asynchronously.
setAsync(long, Persistable, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Gains ownership of an item and sets its contents asynchronously.
setException(Throwable) - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
setListener(long, CacheListener) - Method in interface co.paralleluniverse.galaxy.Cache
Sets a listener listening for local cache events on the given item.
setListener(long, CacheListener) - Method in interface co.paralleluniverse.galaxy.Store
Sets a listener listening for local cache events on the given item.
setListenerIfAbsent(long, CacheListener) - Method in interface co.paralleluniverse.galaxy.Cache
Sets a listener listening for local cache events on the given item if absent.
setListenerIfAbsent(long, CacheListener) - Method in interface co.paralleluniverse.galaxy.Store
Sets a listener listening for local cache events on the given item if absent.
setNodeProperty(String, Object) - Method in interface co.paralleluniverse.galaxy.Cluster
Sets a property for this node.
setReady(boolean) - Method in class co.paralleluniverse.common.spring.Service
Sets the readiness of this service.
setResult(V) - Method in class co.paralleluniverse.common.concurrent.SimpleFuture
 
SHORT - Static variable in class co.paralleluniverse.galaxy.cluster.ReaderWriters
 
shutdown() - Method in class co.paralleluniverse.common.spring.Component
Called when the container is destroyed.
SimpleFuture<V> - Class in co.paralleluniverse.common.concurrent
 
SimpleFuture() - Constructor for class co.paralleluniverse.common.concurrent.SimpleFuture
 
size() - Method in interface co.paralleluniverse.common.io.Persistable
Returns the size in bytes of the object's persisted form.
size() - Method in interface co.paralleluniverse.common.io.Streamable
Returns the size in bytes of the object's serialized form.
slaveAdded(NodeInfo) - Method in interface co.paralleluniverse.galaxy.cluster.SlaveConfigurationListener
Invoked when a new slave was added to this (master) node's group.
SlaveAddressResolver<Address> - Interface in co.paralleluniverse.galaxy.cluster
 
SlaveConfigurationListener - Interface in co.paralleluniverse.galaxy.cluster
A listener for events relating to this master-slaves node group configuration.
slaveRemoved(NodeInfo) - Method in interface co.paralleluniverse.galaxy.cluster.SlaveConfigurationListener
Invoked when a slave has left this (master) node's group (it's gone offline).
slice(ByteBuffer, int, int) - Static method in class co.paralleluniverse.common.io.Persistables
Returns a newly allocated ByteBuffer.slice() of a given ByteBuffer.
slice(ByteBuffer, int) - Static method in class co.paralleluniverse.common.io.Persistables
Returns a newly allocated ByteBuffer.slice(), starting from the current position, of a given ByteBuffer.
start(String) - Static method in class co.paralleluniverse.galaxy.Server
Starts the galaxy server.
start(String, String) - Static method in class co.paralleluniverse.galaxy.Server
Starts the galaxy server.
startGlxServer(String, String) - Static method in class co.paralleluniverse.galaxy.testing.GalaxyTestingUtils
 
startZookeeper(String, String) - Static method in class co.paralleluniverse.galaxy.testing.GalaxyTestingUtils
 
store() - Method in class co.paralleluniverse.galaxy.Grid
Returns the grid's distributed data-store service.
Store - Interface in co.paralleluniverse.galaxy
The grid's distributed data-store service.
StoreTransaction - Class in co.paralleluniverse.galaxy
Represents a grid data-store transaction.
StoreTransaction() - Constructor for class co.paralleluniverse.galaxy.StoreTransaction
 
Streamable - Interface in co.paralleluniverse.common.io
This interface marks an object that can be serialized to a data stream.
Streamables - Class in co.paralleluniverse.common.io
Provides utility methods for working with Streamables and/or data streams.
Streamables() - Constructor for class co.paralleluniverse.common.io.Streamables
 
STRING - Static variable in class co.paralleluniverse.galaxy.cluster.ReaderWriters
 
switchToMaster() - Method in interface co.paralleluniverse.galaxy.cluster.LifecycleListener
Invoked when this (formerly) slave node has now become the master.

T

TimeoutException - Exception in co.paralleluniverse.galaxy
Thrown when an operation has timed-out.
TimeoutException(Throwable) - Constructor for exception co.paralleluniverse.galaxy.TimeoutException
 
TimeoutException(String) - Constructor for exception co.paralleluniverse.galaxy.TimeoutException
 
TimeoutException(String, Throwable) - Constructor for exception co.paralleluniverse.galaxy.TimeoutException
 
TimeoutException() - Constructor for exception co.paralleluniverse.galaxy.TimeoutException
 
toByteArray(ByteBuffer) - Static method in class co.paralleluniverse.common.io.ByteBufferUtil
 
toByteArray(ByteBuffer) - Static method in class co.paralleluniverse.common.io.Persistables
Returns an array containing a ByteBuffer's remaining contents.
toByteArray(Streamable) - Static method in class co.paralleluniverse.common.io.Streamables
Serializes a Streamable into a byte array.
toDataInput(InputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer
 
toDataOutput(OutputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer
 
toObjectInput(InputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer
 
toObjectOutput(OutputStream) - Static method in class co.paralleluniverse.io.serialization.JDKSerializer
 
toString() - Method in class co.paralleluniverse.common.spring.Component
 
tryPin(long, ItemState, StoreTransaction) - Method in interface co.paralleluniverse.galaxy.Store
Pins item if it can be done locally.

U

update(byte) - Method in class co.paralleluniverse.common.io.HashFunctionChecksum
 
update(byte[]) - Method in class co.paralleluniverse.common.io.HashFunctionChecksum
 
update(ByteBuffer) - Method in class co.paralleluniverse.common.io.HashFunctionChecksum
 

V

valueOf(String) - Static method in enum co.paralleluniverse.galaxy.ItemState
Returns the enum constant of this type with the specified name.
values() - Static method in enum co.paralleluniverse.galaxy.ItemState
Returns an array containing the constants of this enum type, in the order they are declared.
VersionedPersistable - Interface in co.paralleluniverse.common.io
A Persistable that is used by some persistence service that provides automatic versioning.

W

WithExecutor - Interface in co.paralleluniverse.common.concurrent
An object implementing this interface (usually a listener) requests that all of its methods invoked be invoked through the executor.
write(ByteBuffer) - Method in interface co.paralleluniverse.common.io.Persistable
Writes the object to the given ByteBuffer.
Upon return from this method, the buffer's position will have advanced past the written data.
write(DataOutput) - Method in interface co.paralleluniverse.common.io.Streamable
Serializes the object into the given DataOutput,
write(T) - Method in interface co.paralleluniverse.galaxy.cluster.ReaderWriter
 
write(Object) - Method in interface co.paralleluniverse.io.serialization.ByteArraySerializer
 
write(OutputStream, Object) - Method in interface co.paralleluniverse.io.serialization.IOStreamSerializer
 
write(Object) - Method in class co.paralleluniverse.io.serialization.JDKSerializer
 
write(OutputStream, Object) - Method in class co.paralleluniverse.io.serialization.JDKSerializer
 
write(Kryo, Output, T) - Method in class co.paralleluniverse.io.serialization.kryo.ExternalizableKryoSerializer
 
write(Object) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
write(OutputStream, Object) - Method in class co.paralleluniverse.io.serialization.kryo.KryoSerializer
 
write(Object) - Method in class co.paralleluniverse.io.serialization.Serialization
 
write(OutputStream, Object) - Method in class co.paralleluniverse.io.serialization.Serialization
 
writeBuffer(DataOutput, ByteBuffer) - Static method in class co.paralleluniverse.common.io.Streamables
Writes the given ByteBuffer into the given DataOutput.
writeClass(Output, Class) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
writeClassAndObject(Output, Object) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
writeObject(Output, Object, Serializer) - Method in class co.paralleluniverse.io.serialization.kryo.ReplaceableObjectKryo
 
WriteReplace - Interface in co.paralleluniverse.io.serialization
 
writeReplace(Object) - Method in interface co.paralleluniverse.io.serialization.WriteReplace
 
A B C D E F G H I J K L M N O P Q R S T U V W