ABP.Entry |
Deprecated.
|
ABP.Type |
Deprecated.
|
ASYM_ENCRYPT |
Encrypts and decrypts communication in JGroups by using a secret key distributed to all cluster members by the
key server (coordinator) using asymmetric (public/private key) encryption.
The secret key is identical for all cluster members and is used to encrypt messages when sending and decrypt them
when receiving messages.
|
ASYM_ENCRYPT.Processing |
|
AUTH |
The AUTH protocol adds a layer of authentication to JGroups.
|
AuthHeader |
AuthHeader is a holder object for the token that is passed from the joiner to the coordinator
|
BaseBundler |
Implements storing of messages in a hashmap and sending of single messages and message batches.
|
BasicTCP |
Shared base class for TCP protocols
|
Bundler |
Pluggable way to collect messages and send them as batches
|
COUNTER.ReconcileResponse |
|
COUNTER.ReconciliationTask |
|
COUNTER.Request |
|
COUNTER.RequestType |
|
COUNTER.Response |
|
COUNTER.ResponseType |
|
COUNTER.SetRequest |
|
COUNTER.SimpleRequest |
|
COUNTER.SimpleResponse |
Response without data
|
COUNTER.ValueResponse |
|
COUNTER.VersionedValue |
|
DH_KEY_EXCHANGE.DhHeader |
|
DH_KEY_EXCHANGE.Type |
|
DISCARD |
Discards up or down messages based on a percentage; e.g., setting property 'up' to 0.1 causes 10%
of all up messages to be discarded.
|
DISCARD.DiscardDialog |
|
Discovery |
The Discovery protocol retrieves the initial membership (used by GMS and MERGE3) by sending discovery requests.
|
DROP |
Protocol which drops up or down messages according to user-defined filters
|
DUPL.Direction |
|
Encrypt |
|
EncryptHeader |
|
Executing |
This is the base protocol used for executions.
|
Executing.Owner |
|
Executing.Request |
|
Executing.Type |
|
FailureDetection |
|
FcHeader |
Header used by various flow control protocols
|
FD_ALL3.Bitmap |
|
FD_HOST |
Failure detection protocol which detects the crash or hanging of entire hosts and suspects all cluster members
on those hosts.
|
FD_HOST.PingCommand |
Command used to check whether a given host is alive, periodically called
|
FD_SOCK.BroadcastTask |
Task that periodically broadcasts a list of suspected members to the group.
|
FD_SOCK.ClientConnectionHandler |
Handles a client connection; multiple client can connect at the same time
|
FD_SOCK.FdHeader |
|
FD_SOCK.ServerSocketHandler |
Handles the server-side of a client-server socket connection.
|
FD.Broadcaster |
Task that periodically broadcasts a list of suspected members to the group.
|
FD.BroadcastTask |
|
FILE_PING |
Simple discovery protocol which uses a file on shared storage such as an SMB share, NFS mount or S3.
|
FlowControl |
Simple flow control protocol based on a credit system.
|
FRAG2 |
Fragmentation layer.
|
FRAG2.FragEntry |
Class represents an entry for a message.
|
FRAG3 |
Fragmentation protocol which uses less memory to store fragments than FRAG2 .
When a message is fragmented, all fragments carry the size of the original message, their offset and
length with respect to the original message and a fragment ID (to identify the fragment).
When the first fragment is received, the full message is created and each fragment copies its data into the full
message at its offset and length.
|
FRAG3.FragEntry |
Entry for a full message, received fragments are copied into buffer and set in the bitset of expected frags.
|
Frag3Header |
|
FragHeader |
|
KeyExchange |
Base class for protocols implementing key exchange: a secret key to be used for encryption is exchanged between
2 parties (usually the key server and a new cluster member) securely; ie.
|
Locking |
Base locking protocol, handling most of the protocol communication with other instances.
|
Locking.ClientCondition |
|
Locking.ClientLock |
Implementation of Lock .
|
Locking.ClientLockTable |
Manages access to client locks
|
Locking.LockInfoResponse |
|
Locking.Request |
|
Locking.Response |
A response to a request, to be sent back to the requester as a message
|
Locking.ServerCondition |
|
Locking.ServerLock |
Server side queue for handling of lock requests (lock, release).
|
Locking.Type |
|
MAKE_BATCH |
Intercepts individual up messages and creates batches from them, passing the batches up.
|
MERGE3 |
Protocol to discover subgroups; e.g., existing due to a network partition (that healed).
|
MERGE3.InfoSender |
|
MERGE3.MergeHeader |
|
MERGE3.MergeHeader.Type |
|
MFC |
Simple flow control protocol based on a credit system.
|
MFC_NB |
Non-blocking alternative to MFC .
JIRA: JIRA: https://issues.jboss.org/browse/JGRP-2172
|
MPING |
Uses its own IP multicast socket to send and receive discovery requests/responses.
|
MsgStats |
Class which has all the stats about received/sent messages etc (in TP)
|
NAMING.Header |
|
NAMING.Type |
|
NoBundler |
Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g.
|
PING |
The PING protocol retrieves the initial membership by mcasting a discovery request (via the multicast capable
transport) to all current cluster members
|
PingData |
Encapsulates information about a cluster node, e.g.
|
PingHeader |
Used to send discovery requests and responses
|
RACKSPACE_PING.RackspaceClient |
A thread safe Rackspace ReST client
|
RATE |
Measures incoming and outgoing rates: messages/sec, bytes/sec.
|
RED |
Implementation of Random Early Drop: messages are discarded when the bundler's queue in the transport nears exhaustion.
|
RELAY |
Deprecated.
|
RELAY.RelayHeader |
Deprecated.
|
RELAY.RelayHeader.Type |
|
RELAY.ViewData |
Deprecated.
Contains local and remote views, and UUID information
|
REVERSE |
Reverses the next N messages that are received.
|
RingBufferBundler |
|
RingBufferBundlerLockless2 |
Lockless bundler using a reader thread which is unparked by (exactly one) writer thread.
|
RSVP.Entry |
|
S3_PING |
Deprecated.
|
SaslHeader |
|
SaslHeader.Type |
|
SEQUENCER.Flusher |
|
SEQUENCER.SequencerHeader |
|
SEQUENCER2.SequencerHeader |
|
SHARED_LOOPBACK |
Loopback transport shared by all channels within the same VM.
|
SHUFFLE |
Reorders messages by buffering them and shuffling the result after TIMEOUT ms.
|
SimpleTCP.Acceptor |
Calls ServerSocket.accept() and creates new Connection objects
|
SimpleTCP.Connection |
1 connection per peer to send and receive messages
|
SOS |
Periodically fetches some attributes and writes them to a file (https://issues.redhat.com/browse/JGRP-2402)
|
SSL_KEY_EXCHANGE |
Key exchange based on SSL sockets.
|
SSL_KEY_EXCHANGE.SessionVerifier |
|
SSL_KEY_EXCHANGE.Type |
|
STOMP.ClientVerb |
|
STOMP.Connection |
Class which handles a connection to a client
|
STOMP.Frame |
|
STOMP.ServerVerb |
|
STOMP.StompHeader |
|
STOMP.StompHeader.Type |
|
SWIFT_PING.SwiftClient |
A thread safe Swift client
|
SYM_ENCRYPT |
Encrypts and decrypts communication in JGroups by using a secret key shared by all cluster members.
|
TCP |
TCP based protocol.
|
TCPPING |
The TCPPING protocol defines a static cluster membership.
|
TP |
Generic transport - specific implementations should extend this abstract class.
|
TpHeader |
Generic transport header, used by TP.
|
TransferQueueBundler |
This bundler adds all (unicast or multicast) messages to a queue until max size has been exceeded, but does send
messages immediately when no other messages are available.
|
TUNNEL.TUNNELPolicy |
|
UDP |
IP multicast transport based on UDP.
|
UDP.PacketReceiver |
|
UFC |
Simple flow control protocol based on a credit system.
|
UFC_NB |
Non-blocking alternative to UFC .
JIRA: https://issues.jboss.org/browse/JGRP-2172
|
UNICAST3 |
Reliable unicast protocol using a combination of positive and negative acks.
|
UNICAST3.Entry |
|
UNICAST3.ReceiverEntry |
|
UNICAST3.SenderEntry |
|
UNICAST3.State |
|
UnicastHeader3 |
Moved out of UNICAST3 into separate class.
|
VERIFY_SUSPECT |
Catches SUSPECT events traveling up the stack.
|
VERIFY_SUSPECT.Entry |
|