Package | Description |
---|---|
com.hazelcast.cp.internal |
Contains implementation of CP Subsystem
|
com.hazelcast.cp.internal.datastructures.spi.blocking |
Contains the interfaces and abstractions that are implemented / extended
by blocking Raft services, such as Lock, Semaphore, and CountDownLatch
|
com.hazelcast.cp.internal.datastructures.spi.blocking.operation |
Contains the operations that are used by the
AbstractBlockingService abstraction |
com.hazelcast.cp.internal.raft.impl.state |
Contains classes that keep state of Raft nodes
|
com.hazelcast.cp.internal.raftop.metadata |
Contains operations that are used in the Metadata CP group
|
com.hazelcast.cp.internal.session |
Contains service classes
for the Raft-based
ISemaphore implementation |
com.hazelcast.cp.internal.session.operation |
Contains operations that are internally used by the CP session API
|
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.
|
Modifier and Type | Method and Description |
---|---|
MembershipChangeSchedule |
MetadataRaftGroupManager.completeRaftGroupMembershipChanges(long commitIndex,
Map<CPGroupId,BiTuple<Long,Long>> changedGroups) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<BiTuple<String,UUID>,BiTuple<Long,Long>> |
ResourceRegistry.waitTimeouts |
protected ConcurrentMap<BiTuple<String,UUID>,BiTuple<Long,Long>> |
ResourceRegistry.waitTimeouts |
Modifier and Type | Method and Description |
---|---|
Collection<BiTuple<Address,Long>> |
ResourceRegistry.getLiveOperations() |
Collection<BiTuple<Address,Long>> |
AbstractBlockingService.getLiveOperations(CPGroupId groupId) |
Map<BiTuple<String,UUID>,BiTuple<Long,Long>> |
ResourceRegistry.getWaitTimeouts() |
Map<BiTuple<String,UUID>,BiTuple<Long,Long>> |
ResourceRegistry.getWaitTimeouts() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBlockingService.expireWaitKeys(CPGroupId groupId,
Collection<BiTuple<String,UUID>> keys) |
Constructor and Description |
---|
ExpireWaitKeysOp(String serviceName,
Collection<BiTuple<String,UUID>> keys) |
Modifier and Type | Method and Description |
---|---|
Collection<BiTuple<Object,InternalCompletableFuture>> |
QueryState.operations()
Returns the queries waiting to be executed.
|
Constructor and Description |
---|
CompleteRaftGroupMembershipChangesOp(Map<CPGroupId,BiTuple<Long,Long>> changedGroups) |
Modifier and Type | Method and Description |
---|---|
void |
RaftSessionService.expireSessions(CPGroupId groupId,
Collection<BiTuple<Long,Long>> sessionsToExpire) |
Constructor and Description |
---|
ExpireSessionsOp(Collection<BiTuple<Long,Long>> sessionIds) |
Modifier and Type | Method and Description |
---|---|
static <X,Y> BiTuple<X,Y> |
BiTuple.of(X element1,
Y element2) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.