Contains helpers for an {@code Accumulator} implementation. @param <E> the type of element which will be accumulated.

Base implementation for dynamic add Config methods.

Base message task for listener registration tasks

Abstract class providing convenience for concrete implementations of an {@link Aggregator} It provides built-in extraction capabilities that may be us

Abstract superclass for {@link org.mockito.stubbing.Answer} to create a mock with a default answer of a proxied class for the target classloader. <p>

Base message task for async tasks @param <P> The client message parameter class @param <T> The task return type

The socket for TPC engine that captures common functionality for the {@link AsyncSocket} and {@link AsyncServerSocket}.

Base class for {@link BackupAccessor} implementations. @param <K> type of keys @param <V> type of values

Configuration base for config types with a factory class and its properties. @param <T> final child type

Internal base class to encapsulate the internals from the interface methods of ReplicatedRecordStore @param <K> key type @param <V> value type

Provides a basic configuration for a split-brain aware data structure. @param <T> type of the config @since 3.10

Base test class for testing CRDT thread safety and replication behaviour. The test will spawn up to {@value #CONCURRENCY} threads that will perform mu

Base class for CRDT replication operations. It supports replicating a map of {@link IdentifiedDataSerializable} values. In the case of CRDT replicatio

Abstract Cache All Partitions request to handle InMemoryFormat which needed for operation provider

Base class for {@link CacheConfig} @param <K> the key type @param <V> the value type

{@link AbstractCacheIterator} provides the core iterator functionality shared by its descendants. <p> <p>The Hazelcast cluster is made out of partitio

Abstract Cache request to handle InMemoryFormat which needed for operation provider

Abstract implementation of {@link com.hazelcast.cache.impl.record.CacheRecord} with key, value and expiration time as internal state. <p>This implemen

Abstract {@link CacheSyncListenerCompleter} implementation which provides storage and management of countdown latches and cache entry listener registr

A {@link CallIdSequence} that provides backpressure by taking the number of in-flight operations into account when before creating a new call-id. <p>

Base callable Message task.

An abstract {@link Channel} implementation. This class is a pure implementation detail, the fact that it exposes some functionality like access to the

A {@link ChannelInitializer} that runs on a member and used for unencrypted channels. It will deal with the exchange of protocols and based on that it

Base class for {@link Callable} classes which need a special TCCL to be set. @param <V> the result type of method {@code call}

Abstract client driver factory with customizable client config.

Abstract proxy collection implementation of {@link com.hazelcast.transaction.TransactionalObject}.

Base class for tests which have to change the {@link Clock} implementation, which works properly only in an isolated node. <p> Use {@link #startIsolat

Common configuration shared by authentication modules provided out-of-the box in Hazelcast. @param <T> self type used in the fluent API

Implementation of {@link MergingValue} for data structures with collections. @param <V> the type of value @since 3.10

The {@link Collection} serializer

Abstract base class for concurrent array queues. @param <E> type of elements in the queue.

Values for the consumer that are expected to be padded.

Values for the producer that are expected to be padded.

Abstract class defining the common test cases for XML and YAML based configuration tests. <p> All common test cases should be defined in this class to

Abstract class for constructors of config classes.

Abstract class defining common test cases for {@link XmlConfigImportVariableReplacementTest} and {@link YamlConfigImportVariableReplacementTest}

Abstract base class for config locators. @see XmlConfigLocator @see YamlConfigLocator

Abstract composite {@link ConfigRecognizer} implementation that uses multiple recognizers under the hood.

Collects non-threadsafe containers for {@link SplitBrainHandlerService} capable data structures. <p> The {@link com.hazelcast.internal.cluster.impl.Cl