Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.client.cache.impl |
Hazelcast JSR-107 aka JCache implementation client side
|
com.hazelcast.client.cache.impl.nearcache.invalidation | |
com.hazelcast.client.cp.internal.datastructures.atomiclong |
Contains client-side proxy impl of
Raft-based
IAtomicLong |
com.hazelcast.client.cp.internal.datastructures.atomicref |
Contains client-side proxy impl of
Raft-based
IAtomicReference |
com.hazelcast.client.cp.internal.session |
Contains client-side impl of the Raft proxy session manager
|
com.hazelcast.client.impl |
Implementation classes of the com.hazelcast.client interfaces
|
com.hazelcast.client.impl.clientside |
Contains most of the client side HazelcastInstance implementation functionality.
|
com.hazelcast.client.impl.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.client.impl.spi.impl |
Provides util classes for the Hazelcast client SPI.
|
com.hazelcast.client.map.impl.nearcache.invalidation | |
com.hazelcast.cp.internal |
Contains implementation of CP Subsystem
|
com.hazelcast.cp.internal.datastructures.atomiclong.proxy |
Contains
IAtomicLong functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.atomicref.proxy |
Contains
IAtomicReference functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.lock.proxy |
Contains
FencedLock functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.operation |
Contains operations for the Raft Invocation SPI
|
com.hazelcast.cp.internal.raft.impl |
Contains implementation classes of the Raft algorithm
|
com.hazelcast.cp.internal.raft.impl.state |
Contains classes that keep state of Raft nodes
|
com.hazelcast.cp.internal.raft.impl.task |
Contains tasks running on leader or leader-candidates.
|
com.hazelcast.cp.internal.session |
Contains service classes
for the Raft-based
ISemaphore implementation |
com.hazelcast.internal.dynamicconfig |
Classes related to Dynamic Configuration.
|
com.hazelcast.internal.longregister |
This package contains LongRegister implementation.
|
com.hazelcast.internal.longregister.client | |
com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
com.hazelcast.internal.util |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
com.hazelcast.internal.util.executor |
This package contains classes related to Util.Executor
|
com.hazelcast.internal.util.futures |
Re-usable implementations of Futures.
|
com.hazelcast.map.impl.nearcache.invalidation | |
com.hazelcast.map.impl.proxy |
Contains map proxy implementation and support classes.
|
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.impl.executionservice |
Contains the API for the
ExecutionService . |
com.hazelcast.spi.impl.executionservice.impl |
Contains the implementation of the
ExecutionService . |
com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
com.hazelcast.spi.impl.operationservice.InternalOperationService implementation. |
Modifier and Type | Method and Description |
---|---|
<K,V> InternalCompletableFuture<Object> |
AbstractCacheService.createCacheConfigOnAllMembersAsync(PreJoinCacheConfig<K,V> cacheConfig) |
InternalCompletableFuture<V> |
CacheProxy.getAndPutAsync(K key,
V value) |
InternalCompletableFuture<V> |
CacheProxy.getAndPutAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<V> |
CacheProxy.getAndRemoveAsync(K key) |
InternalCompletableFuture<V> |
CacheProxy.getAndReplaceAsync(K key,
V value) |
InternalCompletableFuture<V> |
CacheProxy.getAndReplaceAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<V> |
CacheProxy.getAsync(K key) |
InternalCompletableFuture<V> |
CacheProxy.getAsync(K key,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<Void> |
CacheProxy.putAsync(K key,
V value) |
InternalCompletableFuture<Void> |
CacheProxy.putAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<Boolean> |
CacheProxy.putIfAbsentAsync(K key,
V value) |
InternalCompletableFuture<Boolean> |
CacheProxy.putIfAbsentAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<Boolean> |
CacheProxy.removeAsync(K key) |
InternalCompletableFuture<Boolean> |
CacheProxy.removeAsync(K key,
V oldValue) |
InternalCompletableFuture<Boolean> |
CacheProxy.replaceAsync(K key,
V value) |
InternalCompletableFuture<Boolean> |
CacheProxy.replaceAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<Boolean> |
CacheProxy.replaceAsync(K key,
V oldValue,
V newValue) |
InternalCompletableFuture<Boolean> |
CacheProxy.replaceAsync(K key,
V oldValue,
V newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractCacheSyncListenerCompleter.awaitLatch(CountDownLatch countDownLatch,
InternalCompletableFuture future) |
void |
AbstractCacheSyncListenerCompleter.waitCompletionLatch(Integer countDownLatchId,
InternalCompletableFuture future) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<V> |
ClientCacheProxy.getAndPutAsync(K key,
V value) |
InternalCompletableFuture<V> |
ClientCacheProxy.getAndPutAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<V> |
ClientCacheProxy.getAndRemoveAsync(K key) |
InternalCompletableFuture<V> |
ClientCacheProxy.getAndReplaceAsync(K key,
V value) |
InternalCompletableFuture<V> |
ClientCacheProxy.getAndReplaceAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<V> |
ClientCacheProxy.getAsync(K key) |
InternalCompletableFuture<V> |
ClientCacheProxy.getAsync(K key,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
protected InternalCompletableFuture<V> |
NearCachedClientCacheProxy.getAsyncInternal(Object key,
javax.cache.expiry.ExpiryPolicy expiryPolicy,
BiConsumer<V,Throwable> callback) |
InternalCompletableFuture<Void> |
ClientCacheProxy.putAsync(K key,
V value) |
InternalCompletableFuture<Void> |
ClientCacheProxy.putAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.putIfAbsentAsync(K key,
V value) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.putIfAbsentAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
<T> InternalCompletableFuture<ReadResultSet<T>> |
ClientCacheProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.removeAsync(K key) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.removeAsync(K key,
V oldValue) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.replaceAsync(K key,
V value) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.replaceAsync(K key,
V value,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.replaceAsync(K key,
V oldValue,
V newValue) |
InternalCompletableFuture<Boolean> |
ClientCacheProxy.replaceAsync(K key,
V oldValue,
V newValue,
javax.cache.expiry.ExpiryPolicy expiryPolicy) |
InternalCompletableFuture<EventJournalInitialSubscriberState> |
ClientCacheProxy.subscribeToEventJournal(int partitionId) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture |
ClientCacheInvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientCacheInvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<T> |
AtomicRefProxy.alterAndGetAsync(IFunction<T,T> function) |
InternalCompletableFuture<Void> |
AtomicRefProxy.alterAsync(IFunction<T,T> function) |
<R> InternalCompletableFuture<R> |
AtomicRefProxy.applyAsync(IFunction<T,R> function) |
InternalCompletableFuture<Void> |
AtomicRefProxy.clearAsync() |
InternalCompletableFuture<Boolean> |
AtomicRefProxy.compareAndSetAsync(T expect,
T update) |
InternalCompletableFuture<Boolean> |
AtomicRefProxy.containsAsync(T expected) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAndAlterAsync(IFunction<T,T> function) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAndSetAsync(T newValue) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAsync() |
InternalCompletableFuture<Boolean> |
AtomicRefProxy.isNullAsync() |
InternalCompletableFuture<Void> |
AtomicRefProxy.setAsync(T newValue) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture<Object> |
ClientProxySessionManager.closeSession(RaftGroupId groupId,
Long sessionId) |
protected InternalCompletableFuture<Object> |
ClientProxySessionManager.heartbeat(RaftGroupId groupId,
long sessionId) |
Modifier and Type | Class and Description |
---|---|
class |
ClientDelegatingFuture<V>
The Client Delegating Future is used to delegate
ClientInvocationFuture to a user type to be used with further computation stages or
get() . |
class |
ClientInterceptingDelegatingFuture<V>
A specialization of
ClientDelegatingFuture that allows to set an interceptor to be executed
from user thread on ClientInterceptingDelegatingFuture.get() , ClientInterceptingDelegatingFuture.join() or ClientInterceptingDelegatingFuture.joinInternal() . |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<MetricsResultSet> |
HazelcastClientInstanceImpl.readMetricsAsync(Member member,
long startSequence)
Reads the metrics journal for a given number starting from a specific sequence.
|
Modifier and Type | Class and Description |
---|---|
class |
IExecutorDelegatingFuture<V>
An Abstract DelegatingFuture that can cancel a Runnable/Callable that is executed by an
IExecutorService . |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Long> |
ClientRingbufferProxy.addAllAsync(Collection<? extends E> collection,
OverflowPolicy overflowPolicy) |
InternalCompletableFuture<Long> |
ClientRingbufferProxy.addAsync(E item,
OverflowPolicy overflowPolicy) |
InternalCompletableFuture<Void> |
ClientCardinalityEstimatorProxy.addAsync(Object obj) |
InternalCompletableFuture<Long> |
ClientCardinalityEstimatorProxy.estimateAsync() |
InternalCompletableFuture<V> |
NearCachedClientMapProxy.getAsync(K key) |
InternalCompletableFuture<V> |
ClientMapProxy.getAsync(K key) |
InternalCompletableFuture<Void> |
ClientMapProxy.putAllAsync(Map<? extends K,? extends V> m) |
InternalCompletableFuture<V> |
ClientMapProxy.putAsync(K key,
V value) |
InternalCompletableFuture<V> |
ClientMapProxy.putAsync(K key,
V value,
long ttl,
TimeUnit timeunit) |
InternalCompletableFuture<V> |
ClientMapProxy.putAsync(K key,
V value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected InternalCompletableFuture<V> |
NearCachedClientMapProxy.putAsyncInternal(long ttl,
TimeUnit timeunit,
Long maxIdle,
TimeUnit maxIdleUnit,
Object key,
Object value) |
protected InternalCompletableFuture<V> |
ClientMapProxy.putAsyncInternal(long ttl,
TimeUnit timeunit,
Long maxIdle,
TimeUnit maxIdleUnit,
Object key,
Object value) |
<T> InternalCompletableFuture<ReadResultSet<T>> |
ClientMapProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection) |
InternalCompletableFuture<ReadResultSet<E>> |
ClientRingbufferProxy.readManyAsync(long startSequence,
int minCount,
int maxCount,
IFunction<E,Boolean> filter) |
InternalCompletableFuture<V> |
ClientMapProxy.removeAsync(K key) |
protected InternalCompletableFuture<V> |
NearCachedClientMapProxy.removeAsyncInternal(Object key) |
protected InternalCompletableFuture<V> |
ClientMapProxy.removeAsyncInternal(Object key) |
InternalCompletableFuture<Void> |
ClientMapProxy.setAsync(K key,
V value) |
InternalCompletableFuture<Void> |
ClientMapProxy.setAsync(K key,
V value,
long ttl,
TimeUnit timeunit) |
InternalCompletableFuture<Void> |
ClientMapProxy.setAsync(K key,
V value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected InternalCompletableFuture<Void> |
NearCachedClientMapProxy.setAsyncInternal(long ttl,
TimeUnit timeunit,
Long maxIdle,
TimeUnit maxIdleUnit,
Object key,
Object value) |
protected InternalCompletableFuture<Void> |
ClientMapProxy.setAsyncInternal(long ttl,
TimeUnit timeunit,
Long maxIdle,
TimeUnit maxIdleUnit,
Object key,
Object value) |
<R> InternalCompletableFuture<R> |
ClientMapProxy.submitToKey(K key,
EntryProcessor<K,V,R> entryProcessor) |
<R> InternalCompletableFuture<R> |
NearCachedClientMapProxy.submitToKeyInternal(Object key,
EntryProcessor<K,V,R> entryProcessor) |
<R> InternalCompletableFuture<R> |
ClientMapProxy.submitToKeyInternal(Object key,
EntryProcessor<K,V,R> entryProcessor) |
<R> InternalCompletableFuture<Map<K,R>> |
ClientMapProxy.submitToKeys(Set<K> keys,
EntryProcessor<K,V,R> entryProcessor)
|
InternalCompletableFuture<EventJournalInitialSubscriberState> |
ClientMapProxy.subscribeToEventJournal(int partitionId) |
Modifier and Type | Class and Description |
---|---|
class |
ClientInvocationFuture |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture |
ClientMapInvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
ClientMapInvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<T> |
AtomicRefProxy.alterAndGetAsync(IFunction<T,T> function) |
InternalCompletableFuture<Void> |
AtomicRefProxy.alterAsync(IFunction<T,T> function) |
<R> InternalCompletableFuture<R> |
AtomicRefProxy.applyAsync(IFunction<T,R> function) |
InternalCompletableFuture<Void> |
AtomicRefProxy.clearAsync() |
InternalCompletableFuture<Boolean> |
AtomicRefProxy.compareAndSetAsync(T expect,
T update) |
InternalCompletableFuture<Boolean> |
AtomicRefProxy.containsAsync(T expected) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAndAlterAsync(IFunction<T,T> function) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAndSetAsync(T newValue) |
InternalCompletableFuture<T> |
AtomicRefProxy.getAsync() |
InternalCompletableFuture<Boolean> |
AtomicRefProxy.isNullAsync() |
InternalCompletableFuture<Void> |
AtomicRefProxy.setAsync(T newValue) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture<LockOwnershipState> |
FencedLockProxy.doGetLockOwnershipState() |
protected abstract InternalCompletableFuture<LockOwnershipState> |
AbstractFencedLockProxy.doGetLockOwnershipState() |
protected InternalCompletableFuture<Long> |
FencedLockProxy.doLock(long sessionId,
long threadId,
UUID invocationUid) |
protected abstract InternalCompletableFuture<Long> |
AbstractFencedLockProxy.doLock(long sessionId,
long threadId,
UUID invocationUid) |
protected InternalCompletableFuture<Long> |
FencedLockProxy.doTryLock(long sessionId,
long threadId,
UUID invocationUid,
long timeoutMillis) |
protected abstract InternalCompletableFuture<Long> |
AbstractFencedLockProxy.doTryLock(long sessionId,
long threadId,
UUID invocationUid,
long timeoutMillis) |
protected InternalCompletableFuture<Boolean> |
FencedLockProxy.doUnlock(long sessionId,
long threadId,
UUID invocationUid) |
protected abstract InternalCompletableFuture<Boolean> |
AbstractFencedLockProxy.doUnlock(long sessionId,
long threadId,
UUID invocationUid) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture |
ChangeRaftGroupMembershipOp.replicate(RaftNode raftNode) |
protected InternalCompletableFuture |
DefaultRaftReplicateOp.replicate(RaftNode raftNode) |
protected InternalCompletableFuture |
DestroyRaftGroupOp.replicate(RaftNode raftNode) |
protected abstract InternalCompletableFuture |
RaftReplicateOp.replicate(RaftNode raftNode) |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture |
RaftNodeImpl.forceSetTerminatedStatus() |
InternalCompletableFuture |
RaftNode.forceSetTerminatedStatus()
Sets node's status to
RaftNodeStatus.TERMINATED unconditionally
if it's not terminated or stepped down yet. |
InternalCompletableFuture |
RaftIntegration.newCompletableFuture()
Creates a new instance of
SimpleCompletableFuture . |
InternalCompletableFuture |
RaftNodeImpl.query(Object operation,
QueryPolicy queryPolicy) |
InternalCompletableFuture |
RaftNode.query(Object operation,
QueryPolicy queryPolicy)
Executes the given operation on Raft group depending
on the
QueryPolicy |
InternalCompletableFuture |
RaftNodeImpl.replicate(Object operation) |
InternalCompletableFuture |
RaftNode.replicate(Object operation)
Replicates the given operation to the Raft group.
|
InternalCompletableFuture |
RaftNodeImpl.replicateMembershipChange(RaftEndpoint member,
MembershipChangeMode mode) |
InternalCompletableFuture |
RaftNode.replicateMembershipChange(RaftEndpoint member,
MembershipChangeMode mode)
Replicates the membership change to the Raft group.
|
InternalCompletableFuture |
RaftNodeImpl.replicateMembershipChange(RaftEndpoint member,
MembershipChangeMode mode,
long groupMembersCommitIndex) |
InternalCompletableFuture |
RaftNode.replicateMembershipChange(RaftEndpoint member,
MembershipChangeMode mode,
long groupMembersCommitIndex)
Replicates the membership change to the Raft group, if expected members
commit index is equal to the actual one stored in Raft state.
|
InternalCompletableFuture |
RaftNodeImpl.transferLeadership(RaftEndpoint endpoint) |
InternalCompletableFuture |
RaftNode.transferLeadership(RaftEndpoint endpoint)
Transfers group leadership to the given endpoint, if the local Raft node
is the leader with ACTIVE status and the endpoint is a group member.
|
Modifier and Type | Method and Description |
---|---|
void |
RaftNodeImpl.registerFuture(long entryIndex,
InternalCompletableFuture future)
Registers the future for the appended entry with its
entryIndex . |
void |
RaftNodeImpl.runQuery(Object operation,
InternalCompletableFuture resultFuture)
Executes query operation sets execution result to the future.
|
Modifier and Type | Method and Description |
---|---|
Collection<BiTuple<Object,InternalCompletableFuture>> |
QueryState.operations()
Returns the queries waiting to be executed.
|
Modifier and Type | Method and Description |
---|---|
int |
QueryState.addQuery(long commitIndex,
Object operation,
InternalCompletableFuture resultFuture)
Adds the given query to the collection of queries and returns the number
of queries waiting to be executed.
|
boolean |
RaftState.initLeadershipTransfer(RaftEndpoint targetEndpoint,
InternalCompletableFuture resultFuture)
Initializes the leadership transfer state, and returns
true
if the leadership transfer is triggered for the first time
and returns false if there is an ongoing leadership transfer
process. |
void |
LeadershipTransferState.notify(RaftEndpoint targetEndpoint,
InternalCompletableFuture otherFuture) |
Constructor and Description |
---|
InitLeadershipTransferTask(RaftNodeImpl raftNode,
RaftEndpoint targetEndpoint,
InternalCompletableFuture resultFuture) |
MembershipChangeTask(RaftNodeImpl raftNode,
InternalCompletableFuture resultFuture,
RaftEndpoint member,
MembershipChangeMode membershipChangeMode) |
MembershipChangeTask(RaftNodeImpl raftNode,
InternalCompletableFuture resultFuture,
RaftEndpoint member,
MembershipChangeMode membershipChangeMode,
Long groupMembersCommitIndex) |
QueryTask(RaftNodeImpl raftNode,
Object operation,
QueryPolicy policy,
InternalCompletableFuture resultFuture) |
ReplicateTask(RaftNodeImpl raftNode,
Object operation,
InternalCompletableFuture resultFuture) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture<Object> |
ProxySessionManagerService.closeSession(RaftGroupId groupId,
Long sessionId) |
protected abstract InternalCompletableFuture<Object> |
AbstractProxySessionManager.closeSession(RaftGroupId groupId,
Long sessionId)
Closes the given session on the Raft group
|
InternalCompletableFuture<Boolean> |
RaftSessionService.forceCloseSession(String groupName,
long sessionId) |
InternalCompletableFuture<Collection<CPSession>> |
RaftSessionService.getAllSessions(CPGroupId groupId) |
InternalCompletableFuture<Collection<CPSession>> |
RaftSessionService.getAllSessions(String groupName) |
protected InternalCompletableFuture<Object> |
ProxySessionManagerService.heartbeat(RaftGroupId groupId,
long sessionId) |
protected abstract InternalCompletableFuture<Object> |
AbstractProxySessionManager.heartbeat(RaftGroupId groupId,
long sessionId)
Commits a heartbeat for the session on the Raft group
|
Modifier and Type | Method and Description |
---|---|
Map<RaftGroupId,InternalCompletableFuture<Object>> |
AbstractProxySessionManager.shutdown()
Invokes a shutdown call on server to close all existing sessions.
|
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Object> |
ClusterWideConfigurationService.broadcastConfigAsync(IdentifiedDataSerializable config) |
Modifier and Type | Method and Description |
---|---|
protected abstract InternalCompletableFuture |
InvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
InvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
Modifier and Type | Method and Description |
---|---|
static InternalCompletableFuture<Object> |
InvocationUtil.invokeOnStableClusterSerial(NodeEngine nodeEngine,
Supplier<? extends Operation> operationSupplier,
int maxRetries)
Invoke operation on all cluster members.
|
Modifier and Type | Class and Description |
---|---|
class |
CompletableFutureTask<V> |
Modifier and Type | Class and Description |
---|---|
class |
ChainingFuture<T>
Iterates over supplied
InternalCompletableFuture serially. |
Constructor and Description |
---|
ChainingFuture(Iterator<InternalCompletableFuture<T>> futuresToChain,
ChainingFuture.ExceptionHandler exceptionHandler) |
Modifier and Type | Method and Description |
---|---|
protected InternalCompletableFuture |
MemberMapInvalidationMetaDataFetcher.fetchMetadataOf(Address address,
List<String> names) |
Modifier and Type | Method and Description |
---|---|
protected void |
MemberMapInvalidationMetaDataFetcher.extractMemberMetadata(Member member,
InternalCompletableFuture future,
InvalidationMetaDataFetcher.MetadataHolder metadataHolder) |
Modifier and Type | Method and Description |
---|---|
<R> InternalCompletableFuture<R> |
NearCachedMapProxyImpl.executeOnKeyInternal(Object key,
EntryProcessor<K,V,R> entryProcessor,
ExecutionCallback<? super R> callback) |
InternalCompletableFuture<V> |
MapProxyImpl.getAsync(K key) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.getAsyncInternal(Object key) |
InternalCompletableFuture<Void> |
MapProxyImpl.putAllAsync(Map<? extends K,? extends V> map)
This version does not support batching.
|
InternalCompletableFuture<V> |
MapProxyImpl.putAsync(K key,
V value) |
InternalCompletableFuture<V> |
MapProxyImpl.putAsync(K key,
V value,
long ttl,
TimeUnit timeunit) |
InternalCompletableFuture<V> |
MapProxyImpl.putAsync(K key,
V value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.putAsyncInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
InternalCompletableFuture<V> |
MapProxyImpl.removeAsync(K key) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.removeAsyncInternal(Object key) |
InternalCompletableFuture<Void> |
MapProxyImpl.setAsync(K key,
V value) |
InternalCompletableFuture<Void> |
MapProxyImpl.setAsync(K key,
V value,
long ttl,
TimeUnit timeunit) |
InternalCompletableFuture<Void> |
MapProxyImpl.setAsync(K key,
V value,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
protected InternalCompletableFuture<Data> |
NearCachedMapProxyImpl.setAsyncInternal(Object key,
Data valueData,
long ttl,
TimeUnit ttlUnit,
long maxIdle,
TimeUnit maxIdleUnit) |
<R> InternalCompletableFuture<R> |
MapProxyImpl.submitToKey(K key,
EntryProcessor<K,V,R> entryProcessor) |
<R> InternalCompletableFuture<Map<K,R>> |
MapProxyImpl.submitToKeys(Set<K> keys,
EntryProcessor<K,V,R> entryProcessor)
|
<R> InternalCompletableFuture<Map<K,R>> |
NearCachedMapProxyImpl.submitToKeysInternal(Set<K> keys,
Set<Data> dataKeys,
EntryProcessor<K,V,R> entryProcessor) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractInvocationFuture<V>
Custom implementation of
CompletableFuture . |
class |
DelegatingCompletableFuture<V>
A
InternalCompletableFuture implementation that delegates the real logic to an underlying
InternalCompletableFuture and decorates it with additional behavior:
change the returned value by setting the result
caching the deserialized content so that a deserialization only happens once. |
class |
DeserializingCompletableFuture<V>
Decorates
InternalCompletableFuture to supply:
optional value deserialization
custom default async executor
|
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<Void> |
AbstractInvocationFuture.acceptEither(CompletionStage<? extends V> other,
Consumer<? super V> action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.acceptEitherAsync(CompletionStage<? extends V> other,
Consumer<? super V> action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.acceptEitherAsync(CompletionStage<? extends V> other,
Consumer<? super V> action,
Executor executor) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.applyToEither(CompletionStage<? extends V> other,
Function<? super V,U> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.applyToEitherAsync(CompletionStage<? extends V> other,
Function<? super V,U> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.applyToEitherAsync(CompletionStage<? extends V> other,
Function<? super V,U> fn,
Executor executor) |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.completedExceptionally(Throwable t)
Creates a new
InternalCompletableFuture that is completed exceptionally with the
given Throwable . |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.completedExceptionally(Throwable t,
Executor defaultAsyncExecutor)
Creates a new
InternalCompletableFuture that is completed exceptionally with the
given Throwable and uses the given Executor as default executor for
next stages registered with default async methods. |
InternalCompletableFuture<V> |
AbstractInvocationFuture.exceptionally(Function<Throwable,? extends V> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.handle(BiFunction<? super V,Throwable,? extends U> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.handleAsync(BiFunction<? super V,Throwable,? extends U> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.handleAsync(BiFunction<? super V,Throwable,? extends U> fn,
Executor executor) |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newCompletedFuture(Object result)
Creates a new
InternalCompletableFuture that is already completed with the value given
as argument as its completion value. |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newCompletedFuture(Object result,
Executor defaultAsyncExecutor)
Creates a new
InternalCompletableFuture that is already completed with the value given
as argument as its completion value and the provided defaultAsyncExecutor as the default
executor for execution of next stages registered with default async methods (i.e. |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newCompletedFuture(Object result,
SerializationService serializationService)
Creates a new
InternalCompletableFuture that is already completed with the value given
as argument as its completion value. |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newCompletedFuture(Object result,
SerializationService serializationService,
Executor defaultAsyncExecutor)
Creates a new
InternalCompletableFuture that is already completed with the value given
as argument as its completion value and the provided defaultAsyncExecutor as the default
executor for execution of next stages registered with default async methods (i.e. |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newDelegatingFuture(SerializationService serializationService,
InternalCompletableFuture<Data> future)
Creates a new
InternalCompletableFuture that delegates to the given future and
deserializes its completion value of type Data . |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.runAfterBoth(CompletionStage<?> other,
Runnable action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.runAfterBothAsync(CompletionStage<?> other,
Runnable action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.runAfterBothAsync(CompletionStage<?> other,
Runnable action,
Executor executor) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.runAfterEither(CompletionStage<?> other,
Runnable action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.runAfterEitherAsync(CompletionStage<?> other,
Runnable action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.runAfterEitherAsync(CompletionStage<?> other,
Runnable action,
Executor executor) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenAccept(Consumer<? super V> action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenAcceptAsync(Consumer<? super V> action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenAcceptAsync(Consumer<? super V> action,
Executor executor) |
<U> InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenAcceptBoth(CompletionStage<? extends U> other,
BiConsumer<? super V,? super U> action) |
<U> InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenAcceptBothAsync(CompletionStage<? extends U> other,
BiConsumer<? super V,? super U> action) |
<U> InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenAcceptBothAsync(CompletionStage<? extends U> other,
BiConsumer<? super V,? super U> action,
Executor executor) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.thenApply(Function<? super V,? extends U> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.thenApplyAsync(Function<? super V,? extends U> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.thenApplyAsync(Function<? super V,? extends U> fn,
Executor executor) |
<U,R> InternalCompletableFuture<R> |
AbstractInvocationFuture.thenCombine(CompletionStage<? extends U> other,
BiFunction<? super V,? super U,? extends R> fn) |
<U,R> InternalCompletableFuture<R> |
AbstractInvocationFuture.thenCombineAsync(CompletionStage<? extends U> other,
BiFunction<? super V,? super U,? extends R> fn) |
<U,R> InternalCompletableFuture<R> |
AbstractInvocationFuture.thenCombineAsync(CompletionStage<? extends U> other,
BiFunction<? super V,? super U,? extends R> fn,
Executor executor) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.thenCompose(Function<? super V,? extends CompletionStage<U>> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn) |
<U> InternalCompletableFuture<U> |
AbstractInvocationFuture.thenComposeAsync(Function<? super V,? extends CompletionStage<U>> fn,
Executor executor) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenRun(Runnable action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenRunAsync(Runnable action) |
InternalCompletableFuture<Void> |
AbstractInvocationFuture.thenRunAsync(Runnable action,
Executor executor) |
InternalCompletableFuture<V> |
AbstractInvocationFuture.toCompletableFuture() |
InternalCompletableFuture<V> |
AbstractInvocationFuture.whenComplete(BiConsumer<? super V,? super Throwable> action) |
InternalCompletableFuture<V> |
AbstractInvocationFuture.whenCompleteAsync(BiConsumer<? super V,? super Throwable> action) |
InternalCompletableFuture<V> |
AbstractInvocationFuture.whenCompleteAsync(BiConsumer<? super V,? super Throwable> action,
Executor executor) |
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.withExecutor(Executor defaultAsyncExecutor)
Creates a new incomplete
InternalCompletableFuture that uses the given Executor
as default executor for next stages registered with default async methods. |
Modifier and Type | Method and Description |
---|---|
static <V> InternalCompletableFuture<V> |
InternalCompletableFuture.newDelegatingFuture(SerializationService serializationService,
InternalCompletableFuture<Data> future)
Creates a new
InternalCompletableFuture that delegates to the given future and
deserializes its completion value of type Data . |
protected <U> void |
AbstractInvocationFuture.unblockApply(Function<? super V,? extends U> function,
Executor executor,
InternalCompletableFuture<U> future) |
protected <U,R> void |
AbstractInvocationFuture.unblockCombine(CompletionStage<? extends U> other,
BiFunction<? super V,? super U,? extends R> function,
Executor executor,
InternalCompletableFuture<R> future) |
Modifier and Type | Method and Description |
---|---|
<V> InternalCompletableFuture<V> |
ExecutionService.asCompletableFuture(Future<V> future) |
Modifier and Type | Method and Description |
---|---|
<V> InternalCompletableFuture<V> |
ExecutionServiceImpl.asCompletableFuture(Future<V> future) |
Modifier and Type | Class and Description |
---|---|
class |
InvocationFuture<E>
The InvocationFuture is the
InternalCompletableFuture that waits on the completion
of an Invocation . |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.