Uses of Package
org.jgroups.util
Packages that use org.jgroups.util
Package
Description
Provides top-level public JGroups classes such as Channel, Message, etc.
Provides building blocks that are layered on top of channels.
Provides ways to configure a protocol stack.
Provides demonstrations of JGroups functionality.
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
Support for managing protocol stacks.
Provides useful functionality which cannot be assigned to any particular other package.
-
Classes in org.jgroups.util used by org.jgroupsClassDescriptionByte array with an offset and length.
Note that the underlying byte array must not be changed as long as this instance is in use !Represents a message batch; multiple messages from the same sender to the same receiver(s).Allows a thread to submit an asynchronous request and to wait for the result.Interface implementing Streamable and returning the size of the marshalled object.Encapsulates the result of a state transfer.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization -
Classes in org.jgroups.util used by org.jgroups.adminClassDescriptionSimilar to AckCollector, but collects responses from cluster members, not just acks.Interface implementing Streamable and returning the size of the marshalled object.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
-
Classes in org.jgroups.util used by org.jgroups.authClassDescriptionImplementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
-
Classes in org.jgroups.util used by org.jgroups.blocksClassDescriptionMeasures min and max in addition to averageRepresents a message batch; multiple messages from the same sender to the same receiver(s).Keeps track of stats for sync and async unicasts and multicastsContains responses from all members.Interface implementing Streamable and returning the size of the marshalled object.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
-
Classes in org.jgroups.util used by org.jgroups.blocks.atomicClassDescriptionImplementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
-
Classes in org.jgroups.util used by org.jgroups.blocks.csClassDescriptionByte array with an offset and length.
Note that the underlying byte array must not be changed as long as this instance is in use !SimpleRuns a given function in a loop (in a separate thread) until it is stoppedFactory to create various types of sockets and NIO selector provider and channels.Timer-like interface which allows for execution of tasks.Provides a coarse grained time service. -
Classes in org.jgroups.util used by org.jgroups.confClassDescriptionHolds 3 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.
-
Classes in org.jgroups.util used by org.jgroups.demosClassDescriptionImplementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
-
Classes in org.jgroups.util used by org.jgroups.forkClassDescriptionRepresents a message batch; multiple messages from the same sender to the same receiver(s).
-
Classes in org.jgroups.util used by org.jgroups.protocolsClassDescriptionCollects acks from a number of nodes, waits for all acks.Manages ACKs from receivers in
NAKACK4Cache which removes its elements after a certain timeSimple string implemented as a byte[] array.Used to execute asynchronous tasks, e.g.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.Measures min and max in addition to averageBounded linked hashmap; used by SEQUENCERA bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.Base class for message buffers.Byte array with an offset and length.
Note that the underlying byte array must not be changed as long as this instance is in use !ImplementsDataInputover a byte[] buffer.ImplementsDataOutputover a byte[] buffer.Class usingByteBufferand implementingDataOutput.Maintains credits for a unicast destination.Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).Records samples (e.g.Cache which maintains timestamps for keys, and methods to remove/replace expired keys.Class copied fromBitSet.Cache which doesn't remove elements on remove(), removeAll() or retainAll(), but only removes elements when a configurable size limit has been exceeded.A tuple with a long (primitive) first valueRepresents a message batch; multiple messages from the same sender to the same receiver(s).A cache associating members and messagesRepresents an 'owner', which is an address and thread IDA queue with many producers and consumers.Allows a thread to submit an asynchronous request and to wait for the result.Similar to AckCollector, but collects responses from cluster members, not just acks.Manages responses for the discovery protocol.Measures round-trip times (RTT) between nodesRuns a given function in a loop (in a separate thread) until it is stoppedA bitset of missing messages with a fixed size.Interface implementing Streamable and returning the size of the marshalled object.Factory to create various types of sockets and NIO selector provider and channels.SslContextFactory.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serializationLog (usingSuppressCache) which suppresses (certain) messages from the same member for a given timeA store for elements (typically messages) to be retransmitted or delivered.Thread pool based onThreadPoolExecutorTimer-like interface which allows for execution of tasks.The interface that dynamic tasks (TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implementProvides a coarse grained time service.Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.Logical address which is unique over space and time. -
Classes in org.jgroups.util used by org.jgroups.protocols.dns
-
Classes in org.jgroups.util used by org.jgroups.protocols.pbcastClassDescriptionCollects acks from a number of nodes, waits for all acks.Simple string implemented as a byte[] array.Measures min and max in addition to averageBounded input stream.A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.Byte array with an offset and length.
Note that the underlying byte array must not be changed as long as this instance is in use !A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).Class copied fromBitSet.ID to uniquely identify a mergeRepresents a message batch; multiple messages from the same sender to the same receiver(s).A mutable version of Digest.A queue with many producers and consumers.Allows a thread to submit an asynchronous request and to wait for the result.Similar to AckCollector, but collects responses from cluster members, not just acks.Manages responses for the discovery protocol.A bitset of missing messages with a fixed size.Interface implementing Streamable and returning the size of the marshalled object.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serializationLog (usingSuppressCache) which suppresses (certain) messages from the same member for a given timeA store for elements (typically messages) to be retransmitted or delivered.Thread pool based onThreadPoolExecutorTimer-like interface which allows for execution of tasks.The interface that dynamic tasks (TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implementHolds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array. -
Classes in org.jgroups.util used by org.jgroups.protocols.relayClassDescriptionCollects actions by key and executes them - if a predicate is true - every N ms.Subclass of
UUIDaccommodating additional data such as a flag and a small hashmap.Subclass ofUUIDaccommodating additional data such as a flag.Represents a message batch; multiple messages from the same sender to the same receiver(s).Similar to AckCollector, but collects responses from cluster members, not just acks.Interface implementing Streamable and returning the size of the marshalled object.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serializationLog (usingSuppressCache) which suppresses (certain) messages from the same member for a given timeTimer-like interface which allows for execution of tasks.Logical address which is unique over space and time. -
Classes in org.jgroups.util used by org.jgroups.stackClassDescriptionClass using
ByteBufferand implementingDataOutput.List which doesn't remove elements on remove(), removeAll() or retainAll(), but only removes elements when a configurable size limit has been exceeded.Represents a message batch; multiple messages from the same sender to the same receiver(s).Runs a given function in a loop (in a separate thread) until it is stoppedInterface implementing Streamable and returning the size of the marshalled object.Factory to create various types of sockets and NIO selector provider and channels.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serializationTimer-like interface which allows for execution of tasks. -
Classes in org.jgroups.util used by org.jgroups.utilClassDescriptionCollects acks from a number of nodes, waits for all acks.Manages ACKs from receivers in
NAKACK4Simple string implemented as a byte[] array.Used to execute asynchronous tasks, e.g.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.Measures min and max in addition to averageImplementsDataOutputin a generic manner, so that subclasses can implement specific behavior.Base class for message buffers.Byte array with an offset and length.
Note that the underlying byte array must not be changed as long as this instance is in use !ImplementsDataInputover a byte[] buffer.ImplementsDataOutputover a byte[] buffer.Class usingByteBufferand implementingDataOutput.Utility class withCompletableFutureandCompletionStageuseful methods.MPSC queue, based on a ring buffer implementation which optionally blocks on adding or removing of elements.A condition variable with methods for (timed) waiting and signallingMaintains credits for a unicast destination.Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.Thread factory mainly responsible for naming of threads.Collects actions by key and executes them - if a predicate is true - every N ms.A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).Keeps track of one members plus its highest delivered and received seqnosRecords samples (e.g.Copy ofTable.Subclass ofUUIDaccommodating additional data such as a flag and a small hashmap.SimpleClass copied fromBitSet.Subclass ofUUIDaccommodating additional data such as a flag.A hashmap where keys have to be ints.Cache which doesn't remove elements on remove(), removeAll() or retainAll(), but only removes elements when a configurable size limit has been exceeded.A tuple with a long (primitive) first valueMessageProcessingPolicywhich processes regular messages and message batches by assigning a max of 1 thread per message from the same sender.ID to uniquely identify a mergeRepresents a message batch; multiple messages from the same sender to the same receiver(s).A cache associating members and messagesAddress with current time as key.A dummy implementation ofTPA mutable version of Digest.Generic receiver for a JChannelWraps a primitive object (e.g.Wraps an object and its serialized form.Represents an 'owner', which is an address and thread IDA queue with many producers and consumers.Maintains averages for time values measured betweenProfiler.start()andProfiler.stop().Allows a thread to submit an asynchronous request and to wait for the result.Keeps a reference to another objectTable for storing requests associated with monotonically increasing sequence numbers (seqnos).Manages responses for the discovery protocol.Keeps track of stats for sync and async unicasts and multicastsClass that represents a response from a communicationContains responses from all members.Measures round-trip times (RTT) between nodesRuns a given function in a loop (in a separate thread) until it is stoppedA bitset of missing messages with a fixed size.Wraps another input stream and counts the bytes it reads from it.ExtendsOutputStreambut only counts bytes written, doesn't actually write anything.Interface implementing Streamable and returning the size of the marshalled object.Factory to create various types of sockets and NIO selector provider and channels.SslContextFactory.Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serializationDefault message processing policy.Cache which keeps a timestamp and counter for every key.Log (usingSuppressCache) which suppresses (certain) messages from the same member for a given timeA store for elements (typically messages) to be retransmitted or delivered.Thread pool based onThreadPoolExecutorTimer-like interface which allows for execution of tasks.The interface that dynamic tasks (TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implementProvides a coarse grained time service.Lists the types of client authHolds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.Logical address which is unique over space and time.