Package | Description |
---|---|
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.auth | |
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.executor | |
org.jgroups.blocks.locking | |
org.jgroups.blocks.mux | |
org.jgroups.conf |
Provides ways to configure a protocol stack.
|
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Class and Description |
---|
Buffer
Buffer with an offset and length.
|
RspList
Contains responses from all members.
|
TopologyUUID
Subclass of
UUID which adds 3 strings (siteId, rackId and machineId)as payload. |
Class and Description |
---|
Buffer
Buffer with an offset and length.
|
Headers
Open addressing based implementation of a hashmap (not supporting the Map interface though) for message
headers.
|
SocketFactory
Factory to create various types of sockets.
|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
Class and Description |
---|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
Class and Description |
---|
Buffer
Buffer with an offset and length.
|
FutureListener
A listener that is called back when a future is done.
|
NotifyingFuture
A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the
future completes.
|
Rsp
Class that represents a response from a communication
|
RspList
Contains responses from all members.
|
SocketFactory
Factory to create various types of sockets.
|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
ThreadFactory |
Class and Description |
---|
FutureListener
A listener that is called back when a future is done.
|
NotifyingFuture
A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the
future completes.
|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
Class and Description |
---|
Owner
Represents an 'owner', which is an address and thread ID
|
Class and Description |
---|
ImmutableReference
Simple class that holds an immutable reference to another object (or to
null ). |
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
Class and Description |
---|
Tuple
Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate
holder object for the values, and don't want to pass the values as a list or array.
|
Class and Description |
---|
Owner
Represents an 'owner', which is an address and thread ID
|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
Class and Description |
---|
AckCollector
Collects acks from a number of nodes, waits for all acks.
|
AgeOutCache
Cache which removes its elements after a certain time
|
AgeOutCache.Handler |
BoundedList
A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
|
Buffer
Buffer with an offset and length.
|
CreditMap
Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.
|
Owner
Represents an 'owner', which is an address and thread ID
|
Promise
Allows a thread to submit an asynchronous request and to wait for the result.
|
ResponseCollector
Similar to AckCollector, but collects responses, not just acks.
|
SocketFactory
Factory to create various types of sockets.
|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
ThreadFactory |
TimeScheduler
Timer-like interface which allows for execution of tasks.
|
Tuple
Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate
holder object for the values, and don't want to pass the values as a list or array.
|
UUID
Logical address which is unique over space and time.
|
Class and Description |
---|
AckCollector
Collects acks from a number of nodes, waits for all acks.
|
BlockingInputStream
Bounded input stream.
|
BoundedList
A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
|
Digest
A message digest, containing senders and ranges of seqnos, where each sender is associated with its highest delivered
and received seqno seen so far.
|
MergeId
ID to uniquely identify a merge
|
Range |
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
TimeScheduler
Timer-like interface which allows for execution of tasks.
|
Tuple
Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate
holder object for the values, and don't want to pass the values as a list or array.
|
Class and Description |
---|
Seqno
Keeps track of a single message to retransmit
|
SocketFactory
Factory to create various types of sockets.
|
StackType |
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
ThreadFactory |
TimeScheduler
Timer-like interface which allows for execution of tasks.
|
TimeScheduler.Task
The interface that dynamic tasks
(
TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task) ) must implement |
Tuple
Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate
holder object for the values, and don't want to pass the values as a list or array.
|
Class and Description |
---|
AdditionalDataUUID
Subclass of
UUID which adds a string as payload. |
AgeOutCache.Handler |
Buffer
Buffer with an offset and length.
|
DefaultThreadFactory
Thread factory mainly responsible for naming of threads.
|
Digest
A message digest, containing senders and ranges of seqnos, where each sender is associated with its highest delivered
and received seqno seen so far.
|
Digest.DigestEntry
Keeps track of one members plus its highest delivered and received seqnos
|
FutureListener
A listener that is called back when a future is done.
|
HashedTimingWheel.MyTask
Simple task wrapper, always executed by at most 1 thread.
|
Headers
Open addressing based implementation of a hashmap (not supporting the Map interface though) for message
headers.
|
MergeId
ID to uniquely identify a merge
|
MutableDigest
A mutable version of Digest.
|
NotifyingFuture
A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the
future completes.
|
PayloadUUID
Subclass of
UUID which adds a string as payload. |
Promise
Allows a thread to submit an asynchronous request and to wait for the result.
|
Queue
Elements are added at the tail and removed from the head.
|
QueueClosedException |
Range |
Rsp
Class that represents a response from a communication
|
Seqno
Keeps track of a single message to retransmit
|
SocketFactory
Factory to create various types of sockets.
|
StackType |
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
ThreadDecorator
An object that can alter the state of a thread when it receives a callback from a
ThreadManager notifying
it that the thread has been created or released from use. |
ThreadFactory |
ThreadManager
An object that manages threads and provides callbacks to a
ThreadDecorator to allow it to alter their state. |
TimeScheduler
Timer-like interface which allows for execution of tasks.
|
TimeScheduler.Task
The interface that dynamic tasks
(
TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task) ) must implement |
TimeScheduler2.MyTask
Simple task wrapper, always executed by at most 1 thread.
|
TopologyUUID
Subclass of
UUID which adds 3 strings (siteId, rackId and machineId)as payload. |
Tuple
Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate
holder object for the values, and don't want to pass the values as a list or array.
|
Util.AddressScope |
UUID
Logical address which is unique over space and time.
|
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.