Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.auth | |
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.blocks.executor | |
org.jgroups.blocks.mux | |
org.jgroups.demos |
Provides demonstrations of JGroups functionality.
|
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.relay | |
org.jgroups.protocols.tom | |
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Address
Address identifies cluster member.
|
interface |
PhysicalAddress
Represents a physical (as opposed to logical) address
|
Modifier and Type | Class and Description |
---|---|
class |
AnycastAddress
This type of address represents a subset of the cluster members in which the total order properties must be applied,
e.g.
|
class |
Header
Header is a JGroups internal base class for all JGroups headers.
|
class |
MergeView
A view that is sent as a result of a cluster merge.
|
class |
Message
A Message encapsulates data sent to members of a group.
|
class |
View
A view is a local representation of the current membership of a group.
|
class |
ViewId
ViewIds are used for ordering views (each view has a ViewId and a list of members).
|
Modifier and Type | Class and Description |
---|---|
class |
AuthToken
Abstract AuthToken class used by implementations of AUTH, e.g.
|
class |
DemoToken
AuthToken implementation which shows how to send messages back and forth in order to perform authentication.
|
static class |
DemoToken.DemoHeader |
class |
FixedMembershipToken
The FixedMemberShipToken object predefines a list of IP addresses and ports that can join the group.
|
class |
Krb5Token
JGroups AuthToken Class to for Kerberos v5 authentication.
|
class |
MD5Token
This is an example of using a preshared token that is encrypted using an MD5/SHA hash for
authentication purposes.
|
class |
RegexMembership
Matches the IP address or logical name of a joiner against a regular expression and accepts or rejects based on
pattern matching
|
class |
SimpleToken
This is an example of using a preshared token for authentication purposes.
|
class |
X509Token
This is an example of using a preshared token that is encrypted using an X509 certificate for
authentication purposes.
|
Modifier and Type | Class and Description |
---|---|
static class |
GridFile.Metadata |
class |
MethodCall
A method call is the JGroups representation of a remote method.
|
static class |
RequestCorrelator.Header
The header for RequestCorrelator messages
|
static class |
RequestCorrelator.MultiDestinationHeader |
Modifier and Type | Class and Description |
---|---|
protected static class |
Executions.StreamableCallable |
protected static class |
ExecutionService.RunnableAdapter<T>
This is copied from
Executors class which
contains RunnableAdapter. |
Modifier and Type | Class and Description |
---|---|
class |
MuxHeader
Header that identifies the target handler for multiplexed dispatches.
|
Modifier and Type | Class and Description |
---|---|
class |
DrawCommand
Encapsulates information about a draw command.
|
protected static class |
ExecutionServiceDemo.ByteBufferStreamable |
static class |
ExecutionServiceDemo.SortingByteCallable |
static class |
ExecutionServiceDemo.SortingTwoByteCallable
Sorts 2 byte arrys into a larger byte array
|
Modifier and Type | Class and Description |
---|---|
protected static class |
ABP.ABPHeader |
class |
AuthHeader
AuthHeader is a holder object for the token that is passed from the joiner to the coordinator
|
static class |
COMPRESS.CompressHeader |
protected static class |
COUNTER.AddAndGetRequest |
protected static class |
COUNTER.BooleanResponse |
protected static class |
COUNTER.CompareAndSetRequest |
static class |
COUNTER.CounterHeader |
protected static class |
COUNTER.DeleteRequest |
protected static class |
COUNTER.ExceptionResponse |
protected static class |
COUNTER.GetOrCreateRequest |
protected static class |
COUNTER.GetOrCreateResponse |
protected static class |
COUNTER.ReconcileRequest |
protected static class |
COUNTER.ReconcileResponse |
protected static class |
COUNTER.Request |
protected static class |
COUNTER.ResendPendingRequests |
protected static class |
COUNTER.Response |
protected static class |
COUNTER.SetRequest |
protected static class |
COUNTER.SimpleRequest |
protected static class |
COUNTER.SimpleResponse
Response without data
|
protected static class |
COUNTER.UpdateRequest |
protected static class |
COUNTER.ValueResponse |
static class |
DAISYCHAIN.DaisyHeader |
static class |
ENCRYPT.EncryptHeader
Deprecated.
|
class |
EncryptHeader |
static class |
EXAMPLE.ExampleHeader |
static class |
Executing.ExecutorHeader |
protected static class |
Executing.Request |
protected static class |
Executing.RequestWithThread |
class |
FcHeader
Header used by various flow control protocols
|
static class |
FD_ALL.HeartbeatHeader |
static class |
FD_ALL2.HeartbeatHeader |
static class |
FD_SOCK.FdHeader |
static class |
FD.FdHeader |
static class |
FORK.ForkHeader |
protected static class |
FORWARD_TO_COORD.ForwardHeader |
class |
FragHeader |
static class |
Locking.LockingHeader |
static class |
Locking.Request |
protected static class |
MERGE2.MergeHeader
Deprecated.
|
static class |
MERGE3.MergeHeader |
protected static class |
PDC.Mapping |
protected static class |
PERF.PerfHeader |
class |
PingData
Encapsulates information about a cluster node, e.g.
|
class |
PingHeader |
class |
PrioHeader
This Header class is used in conjunction with the PRIO protocol to prioritize message sending/receiving
Priority values are from 0 to 255 where 0 is the highest priority
Example of setting a message priority:
// Create a message to send to everyone
Message message = new Message( null, null, messagePayload );
// Add the priority protocol header
PrioHeader header = new PrioHeader( 1 );
short protocolId = ClassConfigurator.getProtocolId(PRIO.class);
message.putHeader( protocolId, header);
|
static class |
RELAY.RelayHeader |
protected static class |
RELAY.ViewData
Contains local and remote views, and UUID information
|
protected static class |
RSVP.RsvpHeader |
class |
SaslHeader |
static class |
SCOPE.ScopeHeader
Deprecated.
|
static class |
SEQUENCER.SequencerHeader |
static class |
SEQUENCER2.SequencerHeader |
static class |
STOMP.StompHeader |
class |
TpHeader
Generic transport header, used by TP.
|
static class |
UNICAST.UnicastHeader
Deprecated.
The following types and fields are serialized:
|
static class |
UNICAST2.Unicast2Header
Deprecated.
The following types and fields are serialized:
|
static class |
UNICAST3.Header
The following types and fields are serialized:
|
static class |
VERIFY_SUSPECT.VerifyHeader |
Modifier and Type | Method and Description |
---|---|
protected static Streamable |
COUNTER.streamableFromBuffer(byte[] buf,
int offset,
int length) |
Modifier and Type | Method and Description |
---|---|
protected static Buffer |
COUNTER.streamableToBuffer(byte req_or_rsp,
byte type,
Streamable obj) |
Modifier and Type | Class and Description |
---|---|
class |
DeltaView
Subclass of
View with a null members field. |
static class |
FLUSH.FlushHeader |
static class |
GMS.GmsHeader |
class |
JoinRsp
Result of a JOIN request (sent by the GMS client).
|
class |
NakAckHeader |
class |
NakAckHeader2
Header used by
NAKACK2 |
static class |
STABLE.StableHeader |
static class |
STATE_TRANSFER.StateHeader
Wraps data for a state request/response.
|
static class |
StreamingStateTransfer.StateHeader |
Modifier and Type | Interface and Description |
---|---|
interface |
SiteAddress
Address with a site suffix
|
Modifier and Type | Class and Description |
---|---|
class |
CanBeSiteMaster
Deprecated.
Use
ExtendedUUID directly. This class will get dropped in 4.0. |
class |
CanBeSiteMasterTopology
Deprecated.
Use
ExtendedUUID instead. This class will get dropped in 4.0. |
static class |
RELAY2.Relay2Header |
class |
SiteMaster
Special address with the UUID part being 0: identifies the current (relay) coordinator of a given site.
|
class |
SiteUUID
Implementation of SiteAddress
|
Modifier and Type | Class and Description |
---|---|
class |
MessageID
The represents an unique identifier for the messages processed by the Total Order Anycast protocol
Note: it is similar to the ViewId (address + counter)
|
class |
ToaHeader
The header for the Total Order Anycast (TOA) protocol
|
Modifier and Type | Class and Description |
---|---|
class |
GossipData
Encapsulates data sent between GossipRouter and GossipClient
|
class |
IpAddress
Network-dependent address (Internet).
|
Modifier and Type | Interface and Description |
---|---|
interface |
SizeStreamable
Interface implementing Streamable and returning the size of the marshalled object.
|
Modifier and Type | Class and Description |
---|---|
class |
AdditionalDataUUID
Deprecated.
Use
ExtendedUUID instead. Will get dropped in 4.0. |
class |
Average
Maintains an approximation of an average of values.
|
class |
AverageMinMax
Measures min and max in addition to average
|
class |
Digest
A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).
|
class |
ExtendedUUID
Subclass of
UUID accommodating additional data such as a flag and a small hashmap. |
class |
MergeId
ID to uniquely identify a merge
|
class |
MutableDigest
A mutable version of Digest.
|
class |
Owner
Represents an 'owner', which is an address and thread ID
|
class |
PayloadUUID
Deprecated.
Use
ExtendedUUID instead. Will get dropped in 4.0. |
class |
Range |
class |
SeqnoList
A bitset of missing messages with a fixed size.
|
class |
SingletonAddress
Address with a cluster name.
|
class |
TopologyUUID
Deprecated.
Use
ExtendedUUID instead. This class will be dropped in 4.0. |
class |
UUID
Logical address which is unique over space and time.
|
Modifier and Type | Method and Description |
---|---|
static <T extends Streamable> |
Util.read(java.lang.Class<T> clazz,
java.io.DataInput in) |
static <T extends Streamable> |
Util.streamableFromBuffer(java.lang.Class<T> clazz,
byte[] buffer,
int offset,
int length) |
static <T extends Streamable> |
Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl,
byte[] buffer,
int offset,
int length) |
static <T extends Streamable> |
Util.write(T[] array,
java.io.DataOutput out) |
Modifier and Type | Method and Description |
---|---|
static <T extends Streamable> |
Util.read(java.lang.Class<T> clazz,
java.io.DataInput in) |
static Streamable |
Util.readGenericStreamable(java.io.DataInput in) |
static Streamable |
Util.readGenericStreamable(java.io.DataInput in,
java.lang.ClassLoader loader) |
static Streamable |
Util.readStreamable(java.lang.Class clazz,
java.io.DataInput in) |
static Streamable |
Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl,
byte[] buffer) |
static <T extends Streamable> |
Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl,
byte[] buffer,
int offset,
int length) |
Modifier and Type | Method and Description |
---|---|
static Buffer |
Util.streamableToBuffer(Streamable obj) |
static byte[] |
Util.streamableToByteBuffer(Streamable obj) |
static <T extends Streamable> |
Util.write(T[] array,
java.io.DataOutput out) |
static void |
Util.writeGenericStreamable(Streamable obj,
java.io.DataOutput out) |
static void |
Util.writeStreamable(Streamable obj,
java.io.DataOutput out) |
Modifier and Type | Method and Description |
---|---|
static Streamable |
Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl,
byte[] buffer) |
static <T extends Streamable> |
Util.streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl,
byte[] buffer,
int offset,
int length) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.