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.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.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 serializationTimer-like interface which allows for execution of tasks.
-
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.Factory to create various types of sockets.Provides a coarse grained time service.
-
Classes in org.jgroups.util used by org.jgroups.blocks.locking
-
Classes in org.jgroups.util used by org.jgroups.confClassDescriptionA hashmap where keys have to be ints.Holds 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.demosClassDescriptionRepresents an 'owner', which is an address and thread IDImplementations 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.Cache 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 values.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.Byte array with an offset and length.Implements
DataInputover a byte[] buffer.ImplementsDataOutputover a byte[] buffer.Maintains credits for a unicast destination.Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.Cache which maintains timestamps for keys, and methods to remove/replace expired keys.SimpleClass copied fromBitSet.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.Maintains averages for time values measured betweenProfiler.start()andProfiler.stop().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.Ring buffer of fixed capacity designed for multiple writers but only a single reader.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.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.A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).Class copied from
BitSet.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.Timer-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.stackClassDescriptionImplements
DataOutputover a byte[] buffer.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.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.testsClassDescriptionCollects acks from a number of nodes, waits for all acks.Measures min and max in addition to averageByte array with an offset and length.Implements
DataOutputover a byte[] buffer.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.Contains 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.tests.perfClassDescriptionMeasures min and max in addition to averageRepresents 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.Contains 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.tests.rt.transportsClassDescriptionRepresents a message batch; multiple messages from the same sender to the same receiver(s).
-
Classes in org.jgroups.util used by org.jgroups.utilClassDescriptionCollects acks from a number of nodes, waits for all acks.Simple string implemented as a byte[] array.Used to execute asynchronous tasks, e.g.Maintains an approximation of an average of values.Measures min and max in addition to averageImplements
DataOutputin a generic manner, so that subclasses can implement specific behavior.Byte array with an offset and length.ImplementsDataInputover a byte[] buffer.ImplementsDataOutputover a byte[] buffer.Utility class withCompletableFutureandCompletionStageuseful methods.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 seqnosSubclass 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.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 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).Similar to AckCollector, but collects responses from cluster members, not just acks.Task which is seeded with an initial membership.Manages responses for the discovery protocol.Ring buffer of fixed capacity designed for multiple writers but only a single reader.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.Blocking FIFO queue bounded by the max number of bytes of all elements.Interface implementing Streamable and returning the size of the marshalled object.Factory to create various types of sockets.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.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.