| 类和说明 |
|---|
| ExtendedUUID
Subclass of
UUID accommodating additional data such as a flag and a small hashmap. |
| Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
| UUID
Logical address which is unique over space and time.
|
| 类和说明 |
|---|
| Buffer
Buffer with an offset and length.
|
| ByteArrayDataInputStream
Implements
DataInput over a byte[] buffer. |
| 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.
|
| 类和说明 |
|---|
| Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
| 类和说明 |
|---|
| 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 |
| TimeService
Provides a coarse grained time service.
|
| 类和说明 |
|---|
| 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
|
| 类和说明 |
|---|
| Owner
Represents an 'owner', which is an address and thread ID
|
| 类和说明 |
|---|
| 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). |
| 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
|
| 类和说明 |
|---|
| 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.
|
| 类和说明 |
|---|
| 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
|
| 类和说明 |
|---|
| MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
| 类和说明 |
|---|
| AckCollector
Collects acks from a number of nodes, waits for all acks.
|
| AgeOutCache
Cache which removes its elements after a certain time
|
| AgeOutCache.Handler |
| AsciiString
Simple string implemented as a byte[] array.
|
| Average
A class which uses a simple array (of configurable length) to store stats samples.
|
| 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.
|
| ByteArrayDataOutputStream
Implements
DataOutput over a byte[] buffer. |
| 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.
|
| Filter |
| 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).
|
| MessageBatch.Visitor
Used for iteration over the messages
|
| 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.
|
| Responses
Manages responses for the discovery protocol.
|
| 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(TimeScheduler.Task)) must implement |
| TimeService
Provides a coarse grained time service.
|
| 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.
|
| 类和说明 |
|---|
| AckCollector
Collects acks from a number of nodes, waits for all acks.
|
| AsciiString
Simple string implemented as a byte[] array.
|
| 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).
|
| Filter |
| 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.
|
| ProcessingQueue
A queue with many producers and consumers.
|
| ProcessingQueue.Handler |
| Promise
Allows a thread to submit an asynchronous request and to wait for the result.
|
| Range |
| Responses
Manages responses for the discovery protocol.
|
| 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(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.
|
| 类和说明 |
|---|
| ExtendedUUID
Subclass of
UUID accommodating additional data such as a flag and a small hashmap. |
| 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
已过时。
Use
ExtendedUUID instead. This class will be dropped in 4.0. |
| UUID
Logical address which is unique over space and time.
|
| 类和说明 |
|---|
| 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.
|
| 类和说明 |
|---|
| Streamable
Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly
serialization
|
| 类和说明 |
|---|
| MessageBatch
Represents a message batch; multiple messages from the same sender to the same receiver(s).
|
| Responses
Manages responses for the discovery protocol.
|
| 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(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.
|
| 类和说明 |
|---|
| 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
|
| 类和说明 |
|---|
| AdditionalDataUUID
已过时。
Use
ExtendedUUID instead. Will get dropped in 4.0. |
| AgeOutCache.Handler |
| AsciiString
Simple string implemented as a byte[] array.
|
| Average
A class which uses a simple array (of configurable length) to store stats samples.
|
| BoundedHashMap
Bounded linked hashmap; used by SEQUENCER (and probably soon) FORWARD_TO_COORD
|
| Buffer
Buffer with an offset and length.
|
| ByteArrayDataInputStream
Implements
DataInput over a byte[] buffer. |
| ByteArrayDataOutputStream
Implements
DataOutput over a byte[] buffer. |
| 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
|
| ExtendedUUID
Subclass of
UUID accommodating additional data such as a flag and a small hashmap. |
| Filter |
| 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
已过时。
Use
ExtendedUUID instead. Will get dropped in 4.0. |
| Pool.Creator |
| Pool.Element |
| ProcessingQueue
A queue with many producers and consumers.
|
| ProcessingQueue.Handler |
| 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 |
| Responses
Manages responses for the discovery protocol.
|
| 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(TimeScheduler.Task)) must implement |
| TimeScheduler2.MyTask
Simple task wrapper, always executed by at most 1 thread.
|
| TimeScheduler3.Task |
| TimeScheduler3.TaskType |
| TimeService
Provides a coarse grained time service.
|
| TopologyUUID
已过时。
Use
ExtendedUUID instead. This class will be dropped in 4.0. |
| 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.
|