Package | Description |
---|---|
com.hazelcast.cp.internal |
Contains implementation of the 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.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.cp.internal.util |
Contains utilities that are used by the CP subsystem implementation
|
Modifier and Type | Method and Description |
---|---|
MembershipChangeSchedule |
MetadataRaftGroupManager.completeRaftGroupMembershipChanges(long commitIndex,
Map<CPGroupId,Tuple2<Long,Long>> changedGroups) |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Tuple2<String,UUID>,Tuple2<Long,Long>> |
ResourceRegistry.waitTimeouts |
protected ConcurrentMap<Tuple2<String,UUID>,Tuple2<Long,Long>> |
ResourceRegistry.waitTimeouts |
Modifier and Type | Method and Description |
---|---|
Collection<Tuple2<Address,Long>> |
ResourceRegistry.getLiveOperations() |
Collection<Tuple2<Address,Long>> |
AbstractBlockingService.getLiveOperations(CPGroupId groupId) |
Map<Tuple2<String,UUID>,Tuple2<Long,Long>> |
ResourceRegistry.getWaitTimeouts() |
Map<Tuple2<String,UUID>,Tuple2<Long,Long>> |
ResourceRegistry.getWaitTimeouts() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractBlockingService.expireWaitKeys(CPGroupId groupId,
Collection<Tuple2<String,UUID>> keys) |
Constructor and Description |
---|
ExpireWaitKeysOp(String serviceName,
Collection<Tuple2<String,UUID>> keys) |
Constructor and Description |
---|
CompleteRaftGroupMembershipChangesOp(Map<CPGroupId,Tuple2<Long,Long>> changedGroups) |
Modifier and Type | Method and Description |
---|---|
void |
RaftSessionService.expireSessions(CPGroupId groupId,
Collection<Tuple2<Long,Long>> sessionsToExpire) |
Constructor and Description |
---|
ExpireSessionsOp(Collection<Tuple2<Long,Long>> sessionIds) |
Modifier and Type | Method and Description |
---|---|
static <X,Y> Tuple2<X,Y> |
Tuple2.of(X element1,
Y element2) |
Copyright © 2021 Hazelcast, Inc.. All Rights Reserved.