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.admin
org.jgroups.auth
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.atomic
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.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	Message	A Message is used to send data to members of a group.
interface	PhysicalAddress	Represents a physical (as opposed to logical) address

Classes in org.jgroups that implement Streamable

Modifier and Type	Class	Description
class	BaseMessage	A common superclass for all Message implementations.
class	BatchMessage	A message that contains a batch of messages.
class	BytesMessage	A Message containing a byte array as payload.
class	CompositeMessage	A message composed of multiple messages.
class	EmptyMessage	A Message without a payload; optimized for sending only headers (e.g.
class	FragmentedMessage	A message which refers to another message, but only marshals (Streamable.writeTo(DataOutput)) a part of the original message, starting at a given BytesMessage.offset and marshalling only BytesMessage.length bytes.
class	Header	Header is a JGroups internal base class for all JGroups headers.
class	LongMessage	Message with a long as payload.
class	MergeView	A view that is sent as a result of a cluster merge.
class	NioMessage	A Message with a (heap-based or direct) ByteBuffer as payload. Note that the payload of an NioMessage must not be modified after sending it (ie.
class	NullAddress
class	ObjectMessage	A Message with an object as payload.
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.admin

Classes in org.jgroups.admin that implement Streamable

Modifier and Type	Class	Description
class	AdminHeader	Header for admin messages
protected static class	PartitionHandler.ViewInfo

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	RegexMembership	Matches the IP address or logical name of a joiner against a regular expression and accepts or rejects based on pattern matching
class	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 messages
static final class	RequestCorrelator.MultiDestinationHeader

Uses of Streamable in org.jgroups.blocks.atomic

Classes in org.jgroups.blocks.atomic with type parameters of type Streamable

Modifier and Type	Interface	Description
interface	CounterFunction<T extends Streamable>	A function to update AsyncCounter or SyncCounter.

Subinterfaces of Streamable in org.jgroups.blocks.atomic

Modifier and Type	Interface	Description
interface	CounterFunction<T extends Streamable>	A function to update AsyncCounter or SyncCounter.

Methods in org.jgroups.blocks.atomic with type parameters of type Streamable

Modifier and Type	Method	Description
default <T extends Streamable> CompletionStage<T>	AsyncCounter.update(CounterFunction<T> updateFunction)	Atomically updates the counter's value.
default <T extends Streamable> T	SyncCounter.update(CounterFunction<T> updateFunction)	Atomically updates the counter's value.

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.

Uses of Streamable in org.jgroups.protocols

Subinterfaces of Streamable in org.jgroups.protocols

Modifier and Type	Interface	Description
protected static interface	COUNTER.Request

Classes in org.jgroups.protocols that implement Streamable

Modifier and Type	Class	Description
class	AuthHeader	AuthHeader is a holder object for the token that is passed from the joiner to the coordinator
static class	BATCH2.Batch2Header
static class	COMPRESS.CompressHeader
protected static class	COUNTER.AddAndGetRequest
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.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.UpdateRequest
protected static class	COUNTER.ValueResponse
static class	DAISYCHAIN.DaisyHeader
static class	DH_KEY_EXCHANGE.DhHeader
class	EncryptHeader
static class	EXAMPLE.ExampleHeader
static class	FailureDetection.HeartbeatHeader
class	FcHeader	Header used by various flow control protocols
static class	FD_SOCK.FdHeader
static class	FD_SOCK2.FdHeader
static class	FORK.ForkHeader
class	Frag3Header
class	FragHeader
class	InfoHeader	Carries random bits of information
static class	MERGE3.MergeHeader
class	NakAckHeader	Header used by NAKACK3 and NAKACK4
protected static class	PDC.Mapping
class	PerfHeader
class	PingData	Encapsulates information about a cluster node, e.g.
class	PingHeader	Used to send discovery requests and responses
class	ProtPerfHeader
protected static class	RSVP.RsvpHeader
class	RTTHeader	Header to measure round-trip times (in nanoseconds) for sync RPCs (https://issues.redhat.com/browse/JGRP-2604)
static class	SEQUENCER.SequencerHeader
static class	SEQUENCER2.SequencerHeader
static class	STOMP.StompHeader
class	TpHeader	Generic transport header, used by TP.
class	UnicastHeader	Header for subclasses of ReliableUnicast, e.g.
class	UnicastHeader3	Moved out of UNICAST3 into separate class.
static class	VERIFY_SUSPECT.VerifyHeader
static class	VERIFY_SUSPECT2.VerifyHeader
static class	VERSION.VersionHeader

Methods in org.jgroups.protocols with type parameters of type Streamable

Modifier and Type	Method	Description
<T extends Streamable> CompletionStage<T>	COUNTER.CounterImpl.update(CounterFunction<T> updateFunction)

Methods in org.jgroups.protocols with parameters of type Streamable

Modifier and Type	Method	Description
protected static ByteArray	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 of View with a null members field.
static class	GMS.GmsHeader
class	JoinRsp	Result of a JOIN request (sent by the GMS client).
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

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 suffix

Classes in org.jgroups.protocols.relay that implement Streamable

Modifier and Type	Class	Description
class	RelayHeader	Header for RELAY2 and RELAY3
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.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).

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 positive (>= 0) values in a window and adding new values at random indices. This class is lock-less, at the expense of incorrect reads and writes (by multiple threads), but the noise of these errors should be negligible.
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	FlagsUUID	Subclass of UUID accommodating additional data such as a flag.
final class	LongSizeStreamable	Utility class that implements SizeStreamable and LongSupplier to store a long value.
class	MergeId	ID to uniquely identify a merge
class	MillisAddress	Address with current time as key.
class	MutableDigest	A mutable version of Digest.
class	ObjectWrapperPrimitive	Wraps a primitive object (e.g.
class	ObjectWrapperSerializable	Wraps an object and its serialized form.
class	Owner	Represents an 'owner', which is an address and thread ID
class	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(Class<T> clazz, DataInput in)
static <T extends Streamable> T	Util.readGenericStreamable(DataInput in)
static <T extends Streamable> T	Util.readGenericStreamable(DataInput in, ClassLoader loader)
static <T extends Streamable> T	Util.readStreamable(Supplier<T> factory, DataInput in)
static <T extends Streamable> T	Util.streamableFromBuffer(Supplier<T> factory, byte[] buf, int off, int len)
static <T extends Streamable> T	Util.streamableFromByteBuffer(Class<? extends Streamable> cl, byte[] buffer)
static <T extends Streamable> T	Util.streamableFromByteBuffer(Class<? extends Streamable> cl, byte[] buffer, int offset, int length)
static <T extends Streamable> T	Util.streamableFromByteBuffer(Class<? extends Streamable> cl, ByteBuffer buffer)
static <T extends Streamable> T	Util.streamableFromByteBuffer(Supplier<T> factory, byte[] buffer)
static <T extends Streamable> T	Util.streamableFromByteBuffer(Supplier<T> factory, byte[] buffer, int offset, int length)
static <T extends Streamable> void	Util.write(T[] array, DataOutput out)

Methods in org.jgroups.util that return Streamable

Modifier and Type	Method	Description
static <T extends Streamable> T[]	Util.read(Class<T> clazz, DataInput in)

Methods in org.jgroups.util with parameters of type Streamable

Modifier and Type	Method	Description
static ByteArray	Util.streamableToBuffer(Streamable obj)
static byte[]	Util.streamableToByteBuffer(Streamable obj)
static <T extends Streamable> void	Util.write(T[] array, DataOutput out)
static void	Util.writeGenericStreamable(Streamable obj, DataOutput out)
protected static ByteArray	Util.writeStreamable(Streamable obj)
static void	Util.writeStreamable(Streamable obj, DataOutput out)
static void	Util.writeTypeStreamable(Streamable obj, DataOutput out)

Method parameters in org.jgroups.util with type arguments of type Streamable

Modifier and Type	Method	Description
static <T extends Streamable> T	Util.streamableFromByteBuffer(Class<? extends Streamable> cl, byte[] buffer)
static <T extends Streamable> T	Util.streamableFromByteBuffer(Class<? extends Streamable> cl, byte[] buffer, int offset, int length)
static <T extends Streamable> T	Util.streamableFromByteBuffer(Class<? extends Streamable> cl, ByteBuffer buffer)