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.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.rules | |
org.jgroups.stack |
Support for managing protocol stacks.
|
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 |
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.
|
DUPL.Direction |
ENCRYPT.EncryptHeader
Deprecated.
|
EncryptBase
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
Failure detection based on simple heartbeat protocol.
|
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.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 |
FD.Monitor
Task which periodically checks of the last_ack from ping_dest exceeded timeout and - if yes - broadcasts
a SUSPECT message
|
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.
|
FlowControl.Credit |
FRAG2
Fragmentation layer.
|
FRAG2.FragEntry
Class represents an entry for a message.
|
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.
|
MERGE2.FindSubgroupsTask
Deprecated.
Task periodically executing (if role is coordinator).
|
MERGE2.MergeHeader
Deprecated.
|
MERGE3.MergeHeader |
MERGE3.MergeHeader.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 |
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
Discovery protocol using Amazon's S3 storage.
|
SaslHeader |
SaslHeader.Type |
SCOPE.MessageQueue
Deprecated.
|
SCOPE.ScopeHeader
Deprecated.
|
SEQUENCER.Flusher |
SEQUENCER.SequencerHeader |
SEQUENCER2.SequencerHeader |
SHARED_LOOPBACK
Loopback transport shared by all channels within the same VM.
|
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.
|
TP.SingleMessageHandler |
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.PacketReceiver |
UNICAST.ReceiverEntry
Deprecated.
|
UNICAST.SenderEntry
Deprecated.
|
UNICAST.UnicastHeader
Deprecated.
The following types and fields are serialized:
|
UNICAST2.ReceiverEntry
Deprecated.
|
UNICAST2.SenderEntry
Deprecated.
|
UNICAST2.Unicast2Header
Deprecated.
The following types and fields are serialized:
|
UNICAST3.Entry |
UNICAST3.Header
The following types and fields are serialized:
|
UNICAST3.ReceiverEntry |
UNICAST3.SenderEntry |
UNICAST3.State |
VERIFY_SUSPECT.Entry |
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.
|
Copyright © 1998-2020 Red Hat. All Rights Reserved.