| 程序包 | 说明 |
|---|---|
| com.fr.third.jgroups.auth | |
| com.fr.third.jgroups.auth.sasl | |
| com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
| com.fr.third.jgroups.blocks.atomic | |
| com.fr.third.jgroups.blocks.executor | |
| com.fr.third.jgroups.blocks.locking | |
| com.fr.third.jgroups.fork | |
| com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
| com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
| com.fr.third.jgroups.protocols.rules | |
| com.fr.third.jgroups.stack |
Support for managing protocol stacks.
|
| com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
| 类和说明 |
|---|
| AUTH
The AUTH protocol adds a layer of authentication to JGroups
|
| AUTH.UpHandler
Interface to provide callbacks for handling up events
|
| 类和说明 |
|---|
| SaslHeader |
| 类和说明 |
|---|
| TP
Generic transport - specific implementations should extend this abstract class.
|
| 类和说明 |
|---|
| COUNTER
Protocol which is used by
CounterService to provide a distributed atomic counter |
| 类和说明 |
|---|
| Executing
This is the base protocol used for executions.
|
| 类和说明 |
|---|
| Locking
Base locking protocol, handling most of the protocol communication with other instances.
|
| 类和说明 |
|---|
| FORK
The FORK protocol; multiplexes messages to different forks in a stack (https://issues.jboss.org/browse/JGRP-1613).
|
| 类和说明 |
|---|
| 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
|
| BasicTCP
Shared base class for TCP protocols
|
| 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 |
| 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.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 |
| 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
已过时。
Task periodically executing (if role is coordinator).
|
| MERGE2.MergeHeader
已过时。
|
| MERGE3.MergeHeader |
| MERGE3.MergeHeader.Type |
| 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. in case we want to join
the group.
|
| PingData
Encapsulates information about a cluster node, e.g. local address, coordinator's address, logical name and
physical address(es)
|
| PingHeader |
| RELAY.RelayHeader |
| RELAY.RelayHeader.Type |
| RELAY.ViewData
Contains local and remote views, and UUID information
|
| RSVP.Entry |
| S3_PING
Discovery protocol using Amazon's S3 storage.
|
| SaslHeader |
| SaslHeader.Type |
| SCOPE.MessageQueue
已过时。
|
| SCOPE.ScopeHeader
已过时。
|
| SEQUENCER.Flusher |
| SEQUENCER.SequencerHeader |
| SEQUENCER2.SequencerHeader |
| SHARED_LOOPBACK
Loopback transport shared by all channels within the same VM.
|
| 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
|
| TP
Generic transport - specific implementations should extend this abstract class.
|
| TP.BaseBundler |
| TP.Bundler |
| TpHeader
Generic transport header, used by TP.
|
| TUNNEL.TUNNELPolicy |
| UDP.PacketReceiver |
| UNICAST.ReceiverEntry |
| UNICAST.SenderEntry |
| UNICAST.UnicastHeader
The following types and fields are serialized:
| DATA | seqno | conn_id | first |
| ACK | seqno |
| SEND_FIRST_SEQNO |
|
| UNICAST2.ReceiverEntry |
| UNICAST2.SenderEntry |
| UNICAST2.Unicast2Header
The following types and fields are serialized:
| DATA | seqno | conn_id | first |
| ACK | seqno |
| SEND_FIRST_SEQNO | seqno |
|
| UNICAST3.Entry |
| UNICAST3.Header
The following types and fields are serialized:
| DATA | seqno | conn_id | first |
| ACK | seqno | timestamp |
| SEND_FIRST_SEQNO | timestamp |
| CLOSE | conn_id |
|
| UNICAST3.ReceiverEntry |
| UNICAST3.SenderEntry |
| UNICAST3.State |
| VERIFY_SUSPECT.Entry |
| 类和说明 |
|---|
| PingData
Encapsulates information about a cluster node, e.g. local address, coordinator's address, logical name and
physical address(es)
|
| 类和说明 |
|---|
| FD
Failure detection based on simple heartbeat protocol.
|
| 类和说明 |
|---|
| TP
Generic transport - specific implementations should extend this abstract class.
|
| TUNNEL.StubReceiver |
| 类和说明 |
|---|
| PingData
Encapsulates information about a cluster node, e.g. local address, coordinator's address, logical name and
physical address(es)
|