|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use org.jgroups.util | |
---|---|
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.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.protocols.tom | |
org.jgroups.stack | Support for managing protocol stacks. |
org.jgroups.util | Provides useful functionality which cannot be assigned to any particular other package. |
Classes in org.jgroups.util used by org.jgroups | |
---|---|
Buffer
Buffer with an offset and length. |
|
Headers
Open addressing based implementation of a hashmap (not supporting the Map interface though) for message headers. |
|
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. |
Classes in org.jgroups.util used by org.jgroups.auth | |
---|---|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization |
Classes in org.jgroups.util used by org.jgroups.blocks | |
---|---|
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
|
Classes in org.jgroups.util used by org.jgroups.blocks.executor | |
---|---|
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 |
Classes in org.jgroups.util used by org.jgroups.blocks.locking | |
---|---|
Owner
Represents an 'owner', which is an address and thread ID |
Classes in org.jgroups.util used by org.jgroups.blocks.mux | |
---|---|
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 |
Classes in org.jgroups.util used by org.jgroups.conf | |
---|---|
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. |
Classes in org.jgroups.util used by org.jgroups.demos | |
---|---|
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 |
Classes in org.jgroups.util used by org.jgroups.protocols | |
---|---|
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. |
|
ExpiryCache
Cache which maintains timestamps for keys, and methods to remove/replace expired keys. |
|
ForwardQueue
Forwards messages in FIFO order to a destination. |
|
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). |
|
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. |
Classes in org.jgroups.util used by org.jgroups.protocols.pbcast | |
---|---|
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
|
|
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. |
|
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. |
Classes in org.jgroups.util used by org.jgroups.protocols.relay | |
---|---|
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. |
Classes in org.jgroups.util used by org.jgroups.protocols.rules | |
---|---|
BoundedList
A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded. |
|
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. |
Classes in org.jgroups.util used by org.jgroups.protocols.tom | |
---|---|
Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization |
Classes in org.jgroups.util used by org.jgroups.stack | |
---|---|
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. |
Classes in org.jgroups.util used by org.jgroups.util | |
---|---|
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 |
|
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 |
|
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 |
|
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |