Uses of Interface
org.jgroups.util.Streamable
-
Packages that use Streamable 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.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 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. -
-
Uses of Streamable in org.jgroups
Subinterfaces of Streamable in org.jgroups Modifier and Type Interface Description interface
Address
Address identifies cluster member.interface
PhysicalAddress
Represents a physical (as opposed to logical) addressClasses in org.jgroups that implement Streamable Modifier and Type Class 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). -
Uses of Streamable in org.jgroups.auth
Classes in org.jgroups.auth that implement Streamable Modifier and Type Class Description class
AuthToken
Abstract AuthToken class used by implementations of AUTH, e.g.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
Deprecated.Consult the manual for a description of why this token was deprecatedclass
RegexMembership
Matches the IP address or logical name of a joiner against a regular expression and accepts or rejects based on pattern matchingclass
SimpleToken
Deprecated.Consult the manual for a description of why this token was deprecatedclass
X509Token
This is an example of using a preshared token that is encrypted using an X509 certificate for authentication purposes. -
Uses of Streamable in org.jgroups.blocks
Classes in org.jgroups.blocks that implement Streamable Modifier and Type Class 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 messagesstatic class
RequestCorrelator.MultiDestinationHeader
-
Uses of Streamable in org.jgroups.blocks.executor
Classes in org.jgroups.blocks.executor that implement Streamable Modifier and Type Class Description protected static class
Executions.StreamableCallable
protected static class
ExecutionService.RunnableAdapter<T>
This is copied fromExecutors
class which contains RunnableAdapter. -
Uses of Streamable in org.jgroups.demos
Classes in org.jgroups.demos that implement Streamable Modifier and Type Class 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 -
Uses of Streamable in org.jgroups.protocols
Subinterfaces of Streamable in org.jgroups.protocols Modifier and Type Interface Description protected static interface
COUNTER.Request
protected static interface
COUNTER.Response
Classes in org.jgroups.protocols that implement Streamable Modifier and Type Class Description protected static class
ABP.ABPHeader
Deprecated.class
AuthHeader
AuthHeader is a holder object for the token that is passed from the joiner to the coordinatorstatic 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.ResendPendingRequests
protected static class
COUNTER.SetRequest
protected static class
COUNTER.SimpleRequest
protected static class
COUNTER.SimpleResponse
Response without dataprotected static class
COUNTER.UpdateRequest
protected static class
COUNTER.ValueResponse
static class
DAISYCHAIN.DaisyHeader
static class
DH_KEY_EXCHANGE.DhHeader
class
EncryptHeader
static class
EXAMPLE.ExampleHeader
static class
Executing.ExecutorHeader
protected static class
Executing.Request
protected static class
Executing.RequestWithThread
static class
FailureDetection.HeartbeatHeader
class
FcHeader
Header used by various flow control protocolsstatic class
FD_SOCK.FdHeader
static class
FD.FdHeader
static class
FORK.ForkHeader
protected static class
FORWARD_TO_COORD.ForwardHeader
class
Frag3Header
class
FragHeader
protected static class
Locking.LockInfoResponse
static class
Locking.LockingHeader
static class
Locking.Request
static class
MERGE3.MergeHeader
static class
NAMING.Header
protected static class
PDC.Mapping
protected static class
PERF.PerfHeader
class
PingData
Encapsulates information about a cluster node, e.g.class
PingHeader
Used to send discovery requests and responsesstatic class
RELAY.RelayHeader
Deprecated.protected static class
RELAY.ViewData
Deprecated.Contains local and remote views, and UUID informationprotected static class
RSVP.RsvpHeader
class
SaslHeader
static class
SEQUENCER.SequencerHeader
static class
SEQUENCER2.SequencerHeader
static class
STOMP.StompHeader
class
TpHeader
Generic transport header, used by TP.class
UnicastHeader3
Moved out ofUNICAST3
into separate class.static class
VERIFY_SUSPECT.VerifyHeader
Methods in org.jgroups.protocols that return Streamable Modifier and Type Method Description protected static Streamable
COUNTER. streamableFromBuffer(byte[] buf, int offset, int length)
Methods in org.jgroups.protocols with parameters of type Streamable Modifier and Type Method Description protected static Buffer
COUNTER. streamableToBuffer(byte req_or_rsp, byte type, Streamable obj)
-
Uses of Streamable in org.jgroups.protocols.pbcast
Classes in org.jgroups.protocols.pbcast that implement Streamable Modifier and Type Class Description class
DeltaView
Subclass ofView
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
NakAckHeader2
Header used byNAKACK2
static class
STABLE.StableHeader
static class
STATE_TRANSFER.StateHeader
Wraps data for a state request/response.static class
StreamingStateTransfer.StateHeader
-
Uses of Streamable in org.jgroups.protocols.relay
Subinterfaces of Streamable in org.jgroups.protocols.relay Modifier and Type Interface Description interface
SiteAddress
Address with a site suffixClasses in org.jgroups.protocols.relay that implement Streamable Modifier and Type Class Description 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 -
Uses of Streamable in org.jgroups.protocols.tom
Classes in org.jgroups.protocols.tom that implement Streamable Modifier and Type Class Description class
MessageID
The represents an unique identifier for the messages processed by the Total Order Anycast protocolclass
ToaHeader
The header for the Total Order Anycast (TOA) protocol -
Uses of Streamable in org.jgroups.stack
Classes in org.jgroups.stack that implement Streamable Modifier and Type Class Description class
GossipData
Encapsulates data sent between GossipRouter and RouterStub (TCPGOSSIP and TUNNEL)class
IpAddress
Network-dependent address (Internet).class
IpAddressUUID
IpAddress with a 'semi'-UUID to prevent reincarnation when the port is fixed. -
Uses of Streamable in org.jgroups.util
Subinterfaces of Streamable in org.jgroups.util Modifier and Type Interface Description interface
SizeStreamable
Interface implementing Streamable and returning the size of the marshalled object.Classes in org.jgroups.util that implement Streamable Modifier and Type Class Description class
Average
Maintains an approximation of an average of values.class
AverageMinMax
Measures min and max in addition to averageclass
Digest
A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).class
ExtendedUUID
Subclass ofUUID
accommodating additional data such as a flag and a small hashmap.class
FlagsUUID
Subclass ofUUID
accommodating additional data such as a flag.class
MergeId
ID to uniquely identify a mergeclass
MutableDigest
A mutable version of Digest.class
Owner
Represents an 'owner', which is an address and thread IDclass
Range
class
SeqnoList
A bitset of missing messages with a fixed size.class
UUID
Logical address which is unique over space and time.Methods in org.jgroups.util with type parameters of type Streamable Modifier and Type Method Description static <T extends Streamable>
T[]Util. read(java.lang.Class<T> clazz, java.io.DataInput in)
static <T extends Streamable>
TUtil. readGenericStreamable(java.io.DataInput in)
static <T extends Streamable>
TUtil. readGenericStreamable(java.io.DataInput in, java.lang.ClassLoader loader)
static <T extends Streamable>
TUtil. readStreamable(java.util.function.Supplier<T> factory, java.io.DataInput in)
static <T extends Streamable>
TUtil. streamableFromBuffer(java.util.function.Supplier<T> factory, byte[] buf, int off, int len)
static <T extends Streamable>
TUtil. streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer)
static <T extends Streamable>
TUtil. streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer, int offset, int length)
static <T extends Streamable>
TUtil. streamableFromByteBuffer(java.util.function.Supplier<T> factory, byte[] buffer)
static <T extends Streamable>
TUtil. streamableFromByteBuffer(java.util.function.Supplier<T> factory, byte[] buffer, int offset, int length)
static <T extends Streamable>
voidUtil. write(T[] array, java.io.DataOutput out)
Methods in org.jgroups.util that return Streamable Modifier and Type Method Description static <T extends Streamable>
T[]Util. read(java.lang.Class<T> clazz, java.io.DataInput in)
Methods in org.jgroups.util with parameters of type Streamable Modifier and Type Method Description static Buffer
Util. streamableToBuffer(Streamable obj)
static byte[]
Util. streamableToByteBuffer(Streamable obj)
static <T extends Streamable>
voidUtil. 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)
Method parameters in org.jgroups.util with type arguments of type Streamable Modifier and Type Method Description static <T extends Streamable>
TUtil. streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer)
static <T extends Streamable>
TUtil. streamableFromByteBuffer(java.lang.Class<? extends Streamable> cl, byte[] buffer, int offset, int length)
-