Package | Description |
---|---|
org.jgroups.auth | |
org.jgroups.auth.sasl | |
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.atomic | |
org.jgroups.blocks.executor | |
org.jgroups.blocks.locking | |
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.dns | |
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.rules | |
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.tests | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Class and Description |
---|
AUTH
The AUTH protocol adds a layer of authentication to JGroups.
|
AUTH.UpHandler
Interface to provide callbacks for handling up events
|
Class and Description |
---|
SaslHeader |
Class and Description |
---|
TP
Generic transport - specific implementations should extend this abstract class.
|
Class and Description |
---|
COUNTER
Protocol which is used by
CounterService to provide a distributed atomic counter |
Class and Description |
---|
Executing
This is the base protocol used for executions.
|
Class and Description |
---|
Locking
Base locking protocol, handling most of the protocol communication with other instances.
|
Class and Description |
---|
FORK
The FORK protocol; multiplexes messages to different forks in a stack (https://issues.jboss.org/browse/JGRP-1613).
|
Class and Description |
---|
ABP.Entry |
ABP.Type |
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. |
AUTH
The AUTH protocol adds a layer of authentication to JGroups.
|
AUTH.UpHandler
Interface to provide callbacks for handling up events
|
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
Super class of symmetric (
SYM_ENCRYPT ) and asymmetric (ASYM_ENCRYPT ) encryption protocols. |
EncryptHeader |
Executing
This is the base protocol used for executions.
|
Executing.Owner |
Executing.Request |
Executing.Type |
FcHeader
Header used by various flow control protocols
|
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.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 |
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
The responses should allow us to determine the coordinator which we have to contact, e.g.
|
PingData
Encapsulates information about a cluster node, e.g.
|
PingHeader
Used to send discovery requests and responses
|
RELAY.RelayHeader |
RELAY.RelayHeader.Type |
RELAY.ViewData
Contains local and remote views, and UUID information
|
RingBufferBundler
Bundler which uses
RingBuffer to store messages. |
RingBufferBundlerLockless2
Lockless bundler using a reader thread which is unparked by (exactly one) writer thread.
|
RSVP.Entry |
S3_PING
Deprecated.
Use NATIVE_S3_PING (https://github.com/jgroups-extras/native-s3-ping) instead.
S3_PING will be removed in 5.0.
|
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
|
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.
|
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.Entry |
UNICAST3.ReceiverEntry |
UNICAST3.SenderEntry |
UNICAST3.State |
UnicastHeader3
Moved out of
UNICAST3 into separate class. |
VERIFY_SUSPECT.Entry |
Class and Description |
---|
Discovery
The Discovery protocol retrieves the initial membership (used by GMS and MERGE3) by sending discovery requests.
|
Class and Description |
---|
PingData
Encapsulates information about a cluster node, e.g.
|
Class and Description |
---|
FD
Failure detection based on simple heartbeat protocol.
|
Class and Description |
---|
PingData
Encapsulates information about a cluster node, e.g.
|
TP
Generic transport - specific implementations should extend this abstract class.
|
Class and Description |
---|
PingData
Encapsulates information about a cluster node, e.g.
|
Class and Description |
---|
PingData
Encapsulates information about a cluster node, e.g.
|
TP
Generic transport - specific implementations should extend this abstract class.
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.