Uses of Interface
org.jgroups.util.Streamable
Packages that use Streamable
Package
Description
Provides top-level public JGroups classes such as Channel, Message, etc.
Provides building blocks that are layered on top of channels.
Provides demonstrations of JGroups functionality.
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
Supports probabilistic broadcasts.
Support for managing protocol stacks.
Provides useful functionality which cannot be assigned to any particular other package.
-
Uses of Streamable in org.jgroups
Subinterfaces of Streamable in org.jgroupsModifier and TypeInterfaceDescriptioninterfaceAbstract address.interfaceRepresents a physical (as opposed to logical) addressClasses in org.jgroups that implement StreamableModifier and TypeClassDescriptionclassAbstract base class for all headers to be added to a Message.classA view that is sent as a result of a merge.classA Message encapsulates data sent to members of a group.classA view is a local representation of the current membership of a group.classViewIds 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 StreamableModifier and TypeClassDescriptionclassAbstract AuthToken class used by implementations of AUTH, e.g.classThe FixedMemberShipToken object predefines a list of IP addresses and ports that can join the group.classThis is an example of using a preshared token that is encrypted using an MD5/SHA hash for authentication purposes.classMatches the IP address or logical name of a joiner against a regular expression and accepts or rejects based on pattern matchingclassThis is an example of using a preshared token for authentication purposes.classThis 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 StreamableModifier and TypeClassDescriptionstatic classstatic final classDeprecated.static classThe header for RequestCorrelator messagesstatic final class -
Uses of Streamable in org.jgroups.blocks.executor
Classes in org.jgroups.blocks.executor that implement StreamableModifier and TypeClassDescriptionprotected static classprotected static final classThis is copied from class which contains RunnableAdapter. -
Uses of Streamable in org.jgroups.blocks.locking
Classes in org.jgroups.blocks.locking that implement Streamable -
Uses of Streamable in org.jgroups.blocks.mux
Classes in org.jgroups.blocks.mux that implement StreamableModifier and TypeClassDescriptionclassHeader that identifies the target handler for multiplexed dispatches. -
Uses of Streamable in org.jgroups.demos
Classes in org.jgroups.demos that implement StreamableModifier and TypeClassDescriptionclassEncapsulates information about a draw command.static classstatic classSorts 2 byte arrys into a larger byte array -
Uses of Streamable in org.jgroups.mux
Classes in org.jgroups.mux that implement StreamableModifier and TypeClassDescriptionclassHeader used for multiplexing and de-multiplexing between service components on top of a Multiplexer (Channel)classClass used for service state communication between Multiplexers -
Uses of Streamable in org.jgroups.protocols
Classes in org.jgroups.protocols that implement StreamableModifier and TypeClassDescriptionclassAuthHeader is a holder object for the token that is passed from the joiner to the coordinatorstatic classstatic classstatic classstatic classstatic classprotected static classclassHeader used by various flow control protocolsstatic classstatic classstatic classstatic classclassstatic classstatic classprotected static classstatic classstatic classclassEncapsulates information about a cluster node, e.g.classclassThis 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 classprotected static classContains local and remote views, and UUID informationstatic classstatic classstatic classDeprecated.static classstatic classclassGeneric transport header, used by TP.static classThe following types and fields are serialized:static classThe following types and fields are serialized:static classstatic class -
Uses of Streamable in org.jgroups.protocols.pbcast
Classes in org.jgroups.protocols.pbcast that implement StreamableModifier and TypeClassDescriptionstatic classstatic classclassResult of a JOIN request (sent by the GMS client).classstatic classstatic classWraps data for a state request/response.static class -
Uses of Streamable in org.jgroups.stack
Classes in org.jgroups.stack that implement StreamableModifier and TypeClassDescriptionclassEncapsulates data sent between GossipRouter and GossipClientclassNetwork-dependent address (Internet). -
Uses of Streamable in org.jgroups.util
Classes in org.jgroups.util that implement StreamableModifier and TypeClassDescriptionclassSubclass ofUUIDwhich adds a string as payload.classA message digest, which is used by the PBCAST layer for gossiping (also used by NAKACK for keeping track of current seqnos for all members).static classClass keeping track of the lowest and highest sequence numbers delivered, and the highest sequence numbers received, per member.classID to uniquely identify a mergeclassA mutable version of Digest (which is immutableclassSubclass ofUUIDwhich adds a string as payload.classclassAddress with a cluster name.classSubclass ofUUIDwhich adds 3 strings (siteId, rackId and machineId)as payload.classLogical address which is unique over space and time.Methods in org.jgroups.util that return StreamableModifier and TypeMethodDescriptionstatic StreamableUtil.readGenericStreamable(DataInputStream in) static StreamableUtil.readStreamable(Class clazz, DataInputStream in) static StreamableUtil.streamableFromByteBuffer(Class cl, byte[] buffer) static StreamableUtil.streamableFromByteBuffer(Class cl, byte[] buffer, int offset, int length) Methods in org.jgroups.util with parameters of type StreamableModifier and TypeMethodDescriptionstatic intUtil.sizeOf(Streamable inst) static byte[]Util.streamableToByteBuffer(Streamable obj) static voidUtil.writeGenericStreamable(Streamable obj, DataOutputStream out) static voidUtil.writeStreamable(Streamable obj, DataOutputStream out)