Package | Description |
---|---|
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.fork | |
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.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.protocols.tom | |
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.tests | |
org.jgroups.tests.perf | |
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.
|
Headers
Open addressing based implementation of a hashmap (not supporting the Map interface though) for message
headers.
|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
Promise
Allows a thread to submit an asynchronous request and to wait for the result.
|
SocketFactory
Factory to create various types of sockets.
|
StateTransferResult
Encapsulates the result of a state transfer.
|
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.
|
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 |
---|
FutureListener
A listener that is called back when a future is done.
|
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 |
---|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
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 |
BoundedHashMap
Bounded linked hashmap; used by SEQUENCER (and probably soon) FORWARD_TO_COORD
|
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.
|
ExpiryCache
Cache which maintains timestamps for keys, and methods to remove/replace expired keys.
|
ForwardQueue
Forwards messages in FIFO order to a destination.
|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
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.
|
SeqnoList
A list of sequence numbers (seqnos).
|
SingletonAddress
Address with a cluster name.
|
SizeStreamable
Interface implementing Streamable and returning the size of the marshalled object.
|
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
|
SuppressLog
Log (using
SuppressCache ) which suppresses (certain) messages from the same member for a given time |
Table
A store for elements (typically messages) to be retransmitted or delivered.
|
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.
|
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.
|
Buffer
Buffer with an offset and length.
|
Digest
A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).
|
FixedSizeBitSet
Class copied from
BitSet . |
MergeId
ID to uniquely identify a merge
|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
MutableDigest
A mutable version of Digest.
|
Range |
SeqnoList
A list of sequence numbers (seqnos).
|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
SuppressLog
Log (using
SuppressCache ) which suppresses (certain) messages from the same member for a given time |
Table
A store for elements (typically messages) to be retransmitted or delivered.
|
Table.Visitor |
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 |
---|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
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.
|
TopologyUUID
Subclass of
UUID which adds 3 strings (siteId, rackId and machineId)as payload. |
UUID
Logical address which is unique over space and time.
|
Class and Description |
---|
BoundedList
A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
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 |
---|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
Class and Description |
---|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
Seqno
Keeps track of a single message to retransmit
|
SizeStreamable
Interface implementing Streamable and returning the size of the marshalled object.
|
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 |
---|
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.
|
Buffer
Buffer with an offset and length.
|
ResponseCollector
Similar to AckCollector, but collects responses, not just acks.
|
RspList
Contains responses from all members.
|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
Class and Description |
---|
AdditionalDataUUID
Subclass of
UUID which adds a string as payload. |
AgeOutCache.Handler |
BoundedHashMap
Bounded linked hashmap; used by SEQUENCER (and probably soon) FORWARD_TO_COORD
|
Buffer
Buffer with an offset and length.
|
DefaultThreadFactory
Thread factory mainly responsible for naming of threads.
|
Digest
A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).
|
Digest.Entry
Keeps track of one members plus its highest delivered and received seqnos
|
ForwardQueue.Flusher |
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
|
MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
MessageBatch.Mode |
MessageBatch.Visitor
Used for iteration over the messages
|
MutableDigest
A mutable version of Digest.
|
MyReceiver
Generic receiver for a JChannel
|
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
|
SeqnoList
A list of sequence numbers (seqnos).
|
SeqnoList.Seqno |
SeqnoList.SeqnoRange |
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
|
SuppressCache
Cache which keeps a timestamp and counter for every key.
|
SuppressCache.Value |
SuppressLog.Level |
Table.Visitor |
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 |
TimeScheduler2.MyTask
Simple task wrapper, always executed by at most 1 thread.
|
TimeScheduler3.Task |
TimeScheduler3.TaskType |
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 © 2014 JBoss, a division of Red Hat. All rights reserved.