| 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
|
| BARRIER |
All messages up the stack have to go through a barrier (read lock, RL).
|
| BaseBundler |
Implements storing of messages in a hashmap and sending of single messages and message batches.
|
| BasicTCP |
Shared base class for TCP protocols
|
| BATCH.BatchHeader |
|
| BATCH.Buffer |
|
| BATCH2.Batch2Header |
|
| BATCH2.Buffer |
|
| BatchBundler.Buffer |
|
| BPING |
Broadcast PING.
|
| Bundler |
Pluggable way to collect messages and send them as batches
|
| CLEAR_FLAGS |
Protocol which clears a set of flags in the down or up direction for all messages
|
| COMPRESS |
Compresses the payload of a message.
|
| COMPRESS.CompressHeader |
|
| COUNTER |
Protocol which is used by CounterService to provide a distributed atomic counter |
| COUNTER.ReconcileResponse |
|
| COUNTER.ReconciliationTask |
|
| COUNTER.Request |
|
| COUNTER.RequestType |
|
| COUNTER.ResponseType |
|
| COUNTER.SetRequest |
|
| COUNTER.SimpleRequest |
|
| COUNTER.VersionedValue |
|
| DAISYCHAIN.DaisyHeader |
|
| 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 |
Duplicates outgoing or incoming messages by copying them
|
| DUPL.Direction |
|
| Encrypt |
|
| EncryptHeader |
|
| FailureDetection |
|
| FcHeader |
Header used by various flow control protocols
|
| FD_ALL3 |
Failure detection based on simple heartbeat protocol.
|
| 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 |
Failure detection protocol based on sockets.
|
| 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_SOCK2 |
Failure detection protocol based on TCP connections, successor to FD_SOCK. |
| FD_SOCK2.BroadcastTask |
Task which periodically broadcasts a list of suspected members.
|
| FD_SOCK2.FdHeader |
|
| FD_SOCK2.PingDest |
|
| FD_SOCK2.Request |
|
| FD_SOCK2.Request.Type |
|
| FD_SOCK2.State |
|
| 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.
|
| FORK |
The FORK protocol; multiplexes messages to different forks in a stack (https://issues.redhat.com/browse/JGRP-1613).
|
| FRAG2 |
Fragmentation layer.
|
| FRAG2.FragEntry |
Class represents an entry for a message.
|
| FRAG3.FragEntry |
Entry for a full message, received fragments are copied into buffer and set in the bitset of expected frags.
|
| Frag3Header |
|
| FragHeader |
|
| Fragmentation |
Base class for all fragmentation protocols.
|
| HDRS |
Prints the headers of all sent or received messages
|
| JDBC_PING |
Discovery protocol using a JDBC connection to a shared database.
|
| JDBC_PING2 |
|
| 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.
|
| LocalTransport |
A local transport is used for sending messages only to single (or all) members of the same host.
|
| 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.redhat.com/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.
|
| NAKACK4 |
New multicast protocols based on fixed-size xmit windows and message ACKs
Details: https://issues.redhat.com/browse/JGRP-2780
|
| NakAckHeader |
|
| NoBundler |
Bundler which doesn't bundle :-) Can be used to measure the diff between bundling and non-bundling (e.g.
|
| PerDestinationBundler.SendBuffer |
|
| 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
|
| ProtPerfHeader |
|
| RACKSPACE_PING.RackspaceClient |
A thread safe Rackspace ReST client
|
| RATE |
Measures incoming and outgoing rates: messages/sec, bytes/sec.
|
| RATE_LIMITER2 |
Rate limiter based credits (max_bytes).
|
| RED |
Implementation of Random Early Drop: messages are discarded when the bundler's queue in the transport nears exhaustion.
|
| ReliableMulticast |
Base class for reliable multicast protocols
|
| ReliableMulticast.LastSeqnoResender |
Class which is called by RetransmitTask to resend the last seqno sent (if resend_last_seqno is enabled)
|
| 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 |
Protocol which implements synchronous messages (https://issues.redhat.com/browse/JGRP-1389).
|
| RSVP.Entry |
|
| RTTHeader |
Header to measure round-trip times (in nanoseconds) for sync RPCs (https://issues.redhat.com/browse/JGRP-2604)
|
| SEQUENCER |
Implementation of total order protocol using a sequencer.
|
| 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.SSLContextReloader |
Helper class that knows how and when to reload the SSLContext.
|
| 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.
|
| TCP_NIO2 |
Protocol using TCP/IP to send and receive messages.
|
| TCPGOSSIP |
The TCPGOSSIP protocol layer retrieves the initial membership (used by GMS when started by sending event
FIND_INITIAL_MBRS down the stack).
|
| 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.
|
| TransferQueueBundler2 |
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 |
Replacement for UDP.
|
| 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.redhat.com/browse/JGRP-2172 |
| UNBATCH |
|
| 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 |
|
| VERIFY_SUSPECT.VerifyHeader |
|
| VERIFY_SUSPECT2 |
Double-checks that a suspected member is really dead.
Details: https://issues.redhat.com/browse/JGRP-2558
Design: https://github.com/belaban/JGroups/blob/master/doc/design/VERIFY_SUSPECT2.txt
|
| VERIFY_SUSPECT2.Entry |
|
| VERIFY_SUSPECT2.VerifyHeader |
|