Package | Description |
---|---|
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.datastructures.countdownlatch |
Contains client-side proxy impl of
Raft-based
ICountDownLatch |
com.hazelcast.client.cp.internal.datastructures.lock |
Contains client-side proxy impl of
Raft-based
FencedLock |
com.hazelcast.client.cp.internal.datastructures.semaphore |
Contains client-side proxy impl of Raft-based
ISemaphore |
com.hazelcast.cp |
Contains public APIs of CP Subsystem
|
com.hazelcast.cp.exception |
Contains exceptions that can be thrown by APIs of CP Subsystem
|
com.hazelcast.cp.internal |
Contains implementation of CP Subsystem
|
com.hazelcast.cp.internal.datastructures.atomiclong |
Contains service classes for the Raft-based
IAtomicLong implementation |
com.hazelcast.cp.internal.datastructures.atomiclong.operation |
Contains operations for the Raft-based
IAtomicLong implementation |
com.hazelcast.cp.internal.datastructures.atomiclong.proxy |
Contains
IAtomicLong functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.atomicref |
Contains service classes for the Raft-based
IAtomicReference implementation |
com.hazelcast.cp.internal.datastructures.atomicref.operation |
Contains operations for the Raft-based
IAtomicReference implementation |
com.hazelcast.cp.internal.datastructures.atomicref.proxy |
Contains
IAtomicReference functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.countdownlatch |
Contains service classes for the Raft-based
ICountDownLatch implementation |
com.hazelcast.cp.internal.datastructures.countdownlatch.operation |
Contains operations for the Raft-based
ICountDownLatch implementation |
com.hazelcast.cp.internal.datastructures.countdownlatch.proxy |
Contains
IAtomicLong functionality
based on the Raft algorithm. |
com.hazelcast.cp.internal.datastructures.lock |
Contains service classes for the Raft-based
FencedLock
and FencedLock implementation |
com.hazelcast.cp.internal.datastructures.lock.operation |
Contains operations for the Raft-based
FencedLock implementation |
com.hazelcast.cp.internal.datastructures.semaphore |
Contains service classes for the Raft-based
ISemaphore implementation |
com.hazelcast.cp.internal.datastructures.semaphore.operation |
Contains operations for the Raft-based
ISemaphore implementation |
com.hazelcast.cp.internal.datastructures.spi |
Contains the abstractions that is used for managing proxies
for the Raft-based data structure implementations
|
com.hazelcast.cp.internal.datastructures.spi.atomic | |
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.datastructures.spi.operation |
Contains the operations that is used for managing proxies
for the Raft-based data structure implementations
|
com.hazelcast.cp.internal.operation |
Contains operations for the Raft Invocation SPI
|
com.hazelcast.cp.internal.operation.integration |
Contains Hazelcast operations that carry out Raft RPCs
|
com.hazelcast.cp.internal.operation.unsafe | |
com.hazelcast.cp.internal.raft |
Contains abstractions that are defined
for the core Raft algorithm implementation
|
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.raftop |
Contains operations that are used in Hazelcast's Raft implementation
|
com.hazelcast.cp.internal.raftop.metadata |
Contains operations that are used in the Metadata CP group
|
com.hazelcast.cp.internal.raftop.snapshot |
Contains operations that are used by Hazelcast to implement
Raft's snapshotting mechanism
|
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.lock |
Contains locking APIs of CP Subsystem
|
com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
com.hazelcast.spi.impl.operationservice.InternalOperationService implementation. |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
AtomicLongProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
AtomicRefProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
CountDownLatchProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
FencedLockProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
SessionlessSemaphoreProxy.getGroupId() |
CPGroupId |
SessionAwareSemaphoreProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
CPGroup.id()
Returns unique id of the CP group
|
Modifier and Type | Method and Description |
---|---|
CompletionStage<Collection<CPGroupId>> |
CPSubsystemManagementService.getCPGroupIds()
Returns all active CP group ids.
|
Modifier and Type | Method and Description |
---|---|
CPGroupId |
CPGroupDestroyedException.getGroupId() |
Constructor and Description |
---|
CPGroupDestroyedException(CPGroupId groupId) |
NotLeaderException(CPGroupId groupId,
RaftEndpoint local,
RaftEndpoint leader) |
Modifier and Type | Class and Description |
---|---|
class |
RaftGroupId
Implementation of
CPGroupId . |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
MetadataRaftGroupManager.createRaftGroup(String groupName,
Collection<RaftEndpoint> groupEndpoints,
long commitIndex) |
CPGroupId |
CPGroupSummary.id() |
Modifier and Type | Method and Description |
---|---|
InternalCompletableFuture<CPGroupId> |
RaftService.createRaftGroupForProxyAsync(String name) |
Collection<CPGroupId> |
MetadataRaftGroupManager.getActiveGroupIds() |
InternalCompletableFuture<Collection<CPGroupId>> |
RaftService.getAllCPGroupIds() |
InternalCompletableFuture<Collection<CPGroupId>> |
RaftService.getCPGroupIds() |
Collection<CPGroupId> |
MetadataRaftGroupManager.getDestroyingGroupIds() |
Collection<CPGroupId> |
MetadataRaftGroupManager.getGroupIds() |
Collection<CPGroupId> |
RaftService.getLeadedGroups() |
Modifier and Type | Method and Description |
---|---|
boolean |
RaftService.completeFutures(CPGroupId groupId,
Collection<Long> indices,
Object result)
Completes all futures registered with
indices
in the CP group associated with groupId . |
boolean |
RaftService.completeFutures(CPGroupId groupId,
Collection<Map.Entry<Long,Object>> results)
Completes all futures registered with
indices
in the CP group associated with groupId . |
void |
RaftService.createRaftNode(CPGroupId groupId,
Collection<RaftEndpoint> members) |
InternalCompletableFuture<Object> |
RaftInvocationManager.destroy(CPGroupId groupId) |
void |
RaftService.destroyRaftNode(CPGroupId groupId) |
InternalCompletableFuture<CPGroup> |
RaftService.getCPGroup(CPGroupId groupId) |
int |
RaftService.getCPGroupPartitionId(CPGroupId groupId) |
static int |
RaftService.getCPGroupPartitionId(CPGroupId groupId,
int partitionCount) |
CPGroupSummary |
MetadataRaftGroupManager.getGroup(CPGroupId groupId) |
RaftNode |
RaftService.getOrInitRaftNode(CPGroupId groupId) |
RaftNode |
RaftService.getRaftNode(CPGroupId groupId) |
void |
RaftService.handleAppendEntries(CPGroupId groupId,
AppendRequest request,
RaftEndpoint target) |
void |
RaftService.handleAppendResponse(CPGroupId groupId,
AppendFailureResponse response,
RaftEndpoint target) |
void |
RaftService.handleAppendResponse(CPGroupId groupId,
AppendSuccessResponse response,
RaftEndpoint target) |
void |
RaftService.handlePreVoteRequest(CPGroupId groupId,
PreVoteRequest request,
RaftEndpoint target) |
void |
RaftService.handlePreVoteResponse(CPGroupId groupId,
PreVoteResponse response,
RaftEndpoint target) |
void |
RaftService.handleSnapshot(CPGroupId groupId,
InstallSnapshot request,
RaftEndpoint target) |
void |
RaftService.handleTriggerLeaderElection(CPGroupId groupId,
TriggerLeaderElection request,
RaftEndpoint target) |
void |
RaftService.handleVoteRequest(CPGroupId groupId,
VoteRequest request,
RaftEndpoint target) |
void |
RaftService.handleVoteResponse(CPGroupId groupId,
VoteResponse response,
RaftEndpoint target) |
<T> InternalCompletableFuture<T> |
RaftInvocationManager.invoke(CPGroupId groupId,
RaftOp raftOp) |
boolean |
RaftService.isRaftGroupDestroyed(CPGroupId groupId) |
long |
RaftService.nextUnsafeModeCommitIndex(CPGroupId groupId) |
void |
TermChangeAwareService.onNewTermCommit(CPGroupId groupId,
long commitIndex)
Invokes as part of the first commit after a new leader is elected.
|
void |
RaftService.onRaftGroupDestroyed(CPGroupId groupId) |
void |
RaftNodeLifecycleAwareService.onRaftGroupDestroyed(CPGroupId groupId)
Called on the thread of the Raft group when the given Raft node is
destroyed, either gracefully or forcefully.
|
void |
RaftService.onRaftNodeSteppedDown(CPGroupId groupId) |
void |
RaftNodeLifecycleAwareService.onRaftNodeSteppedDown(CPGroupId groupId)
Called on the thread of the Raft group when the given Raft node is
stepped down, either because it is shutting down, or it could not be
added to the Raft group
|
<T> InternalCompletableFuture<T> |
RaftInvocationManager.query(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
<T> InternalCompletableFuture<T> |
RaftInvocationManager.queryLocally(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
void |
RaftService.registerUnsafeWaitingOperation(CPGroupId groupId,
long commitIndex,
Operation op) |
void |
MetadataRaftGroupManager.restoreSnapshot(CPGroupId groupId,
long commitIndex,
MetadataRaftGroupSnapshot snapshot) |
void |
RaftService.restoreSnapshot(CPGroupId groupId,
long commitIndex,
MetadataRaftGroupSnapshot snapshot) |
abstract Object |
RaftOp.run(CPGroupId groupId,
long commitIndex)
Contains actual Raft operation logic.
|
void |
RaftService.stepDownRaftNode(CPGroupId groupId) |
MetadataRaftGroupSnapshot |
MetadataRaftGroupManager.takeSnapshot(CPGroupId groupId,
long commitIndex) |
MetadataRaftGroupSnapshot |
RaftService.takeSnapshot(CPGroupId groupId,
long commitIndex) |
InternalCompletableFuture |
RaftService.transferLeadership(CPGroupId groupId,
CPMemberInfo destination) |
void |
MetadataRaftGroupManager.triggerDestroyRaftGroup(CPGroupId groupId) |
Modifier and Type | Method and Description |
---|---|
void |
MetadataRaftGroupManager.completeDestroyRaftGroups(Set<CPGroupId> groupIds) |
MembershipChangeSchedule |
MetadataRaftGroupManager.completeRaftGroupMembershipChanges(long commitIndex,
Map<CPGroupId,BiTuple<Long,Long>> changedGroups) |
Constructor and Description |
---|
CPGroupSummary(CPGroupId id,
CPGroup.CPGroupStatus status,
Collection<RaftEndpoint> initialMembers,
Collection<CPMember> members) |
Modifier and Type | Method and Description |
---|---|
protected AtomicLong |
AtomicLongService.newAtomicValue(CPGroupId groupId,
String name,
Long val) |
Modifier and Type | Method and Description |
---|---|
Object |
AlterOp.run(CPGroupId groupId,
long commitIndex) |
Object |
ApplyOp.run(CPGroupId groupId,
long commitIndex) |
Object |
LocalGetOp.run(CPGroupId groupId,
long commitIndex) |
Object |
CompareAndSetOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GetAndAddOp.run(CPGroupId groupId,
long commitIndex) |
Object |
AddAndGetOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GetAndSetOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
AtomicLongProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
protected AtomicRef |
AtomicRefService.newAtomicValue(CPGroupId groupId,
String name,
Data val) |
Modifier and Type | Method and Description |
---|---|
Object |
ApplyOp.run(CPGroupId groupId,
long commitIndex) |
Object |
ContainsOp.run(CPGroupId groupId,
long commitIndex) |
Object |
CompareAndSetOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GetOp.run(CPGroupId groupId,
long commitIndex) |
Object |
SetOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
AtomicRefProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
boolean |
CountDownLatchService.await(CPGroupId groupId,
String name,
AwaitInvocationKey key,
long timeoutMillis) |
int |
CountDownLatchService.countDown(CPGroupId groupId,
String name,
UUID invocationUuid,
int expectedRound) |
protected CountDownLatchRegistry |
CountDownLatchService.createNewRegistry(CPGroupId groupId) |
protected CountDownLatch |
CountDownLatchRegistry.createNewResource(CPGroupId groupId,
String name) |
int |
CountDownLatchService.getRemainingCount(CPGroupId groupId,
String name) |
int |
CountDownLatchService.getRound(CPGroupId groupId,
String name) |
boolean |
CountDownLatchService.trySetCount(CPGroupId groupId,
String name,
int count) |
Modifier and Type | Method and Description |
---|---|
Object |
CountDownOp.run(CPGroupId groupId,
long commitIndex) |
Object |
AwaitOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GetRoundOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GetCountOp.run(CPGroupId groupId,
long commitIndex) |
Object |
TrySetCountOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
CountDownLatchProxy.getGroupId() |
Modifier and Type | Method and Description |
---|---|
AcquireResult |
LockService.acquire(CPGroupId groupId,
String name,
LockInvocationKey key,
long timeoutMs) |
protected com.hazelcast.cp.internal.datastructures.lock.LockRegistry |
LockService.createNewRegistry(CPGroupId groupId) |
LockOwnershipState |
LockService.getLockOwnershipState(CPGroupId groupId,
String name) |
boolean |
LockService.release(CPGroupId groupId,
long commitIndex,
String name,
LockEndpoint endpoint,
UUID invocationUid) |
Modifier and Type | Method and Description |
---|---|
Object |
GetLockOwnershipStateOp.run(CPGroupId groupId,
long commitIndex) |
Object |
LockOp.run(CPGroupId groupId,
long commitIndex) |
Object |
TryLockOp.run(CPGroupId groupId,
long commitIndex) |
Object |
UnlockOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
AcquireResult |
SemaphoreService.acquirePermits(CPGroupId groupId,
String name,
AcquireInvocationKey key,
long timeoutMs) |
int |
SemaphoreService.availablePermits(CPGroupId groupId,
String name) |
boolean |
SemaphoreService.changePermits(CPGroupId groupId,
long commitIndex,
String name,
SemaphoreEndpoint endpoint,
UUID invocationUid,
int permits) |
protected SemaphoreRegistry |
SemaphoreService.createNewRegistry(CPGroupId groupId) |
protected Semaphore |
SemaphoreRegistry.createNewResource(CPGroupId groupId,
String name) |
int |
SemaphoreService.drainPermits(CPGroupId groupId,
String name,
long commitIndex,
SemaphoreEndpoint endpoint,
UUID invocationUid) |
boolean |
SemaphoreService.initSemaphore(CPGroupId groupId,
String name,
int permits) |
void |
SemaphoreService.releasePermits(CPGroupId groupId,
long commitIndex,
String name,
SemaphoreEndpoint endpoint,
UUID invocationUid,
int permits) |
Modifier and Type | Method and Description |
---|---|
Object |
ReleasePermitsOp.run(CPGroupId groupId,
long commitIndex) |
Object |
AvailablePermitsOp.run(CPGroupId groupId,
long commitIndex) |
Object |
DrainPermitsOp.run(CPGroupId groupId,
long commitIndex) |
Object |
InitSemaphoreOp.run(CPGroupId groupId,
long commitIndex) |
Object |
ChangePermitsOp.run(CPGroupId groupId,
long commitIndex) |
Object |
AcquirePermitsOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
protected abstract Map<CPGroupId,Object> |
AbstractCPMigrationAwareService.getSnapshotMap(int partitionId) |
Modifier and Type | Method and Description |
---|---|
boolean |
RaftRemoteService.destroyRaftObject(CPGroupId groupId,
String objectName)
Destroys the given CP data structure on the CP group.
|
Modifier and Type | Method and Description |
---|---|
CPGroupId |
RaftAtomicValue.groupId() |
Modifier and Type | Method and Description |
---|---|
protected Map<CPGroupId,Object> |
RaftAtomicValueService.getSnapshotMap(int partitionId) |
Modifier and Type | Method and Description |
---|---|
boolean |
RaftAtomicValueService.destroyRaftObject(CPGroupId groupId,
String name) |
V |
RaftAtomicValueService.getAtomicValue(CPGroupId groupId,
String name) |
protected abstract V |
RaftAtomicValueService.newAtomicValue(CPGroupId groupId,
String name,
T val) |
void |
RaftAtomicValueService.onRaftGroupDestroyed(CPGroupId groupId) |
void |
RaftAtomicValueService.onRaftNodeSteppedDown(CPGroupId groupId) |
void |
RaftAtomicValueService.restoreSnapshot(CPGroupId groupId,
long commitIndex,
S snapshot) |
S |
RaftAtomicValueService.takeSnapshot(CPGroupId groupId,
long commitIndex) |
Constructor and Description |
---|
RaftAtomicValue(CPGroupId groupId,
String name) |
Modifier and Type | Field and Description |
---|---|
protected CPGroupId |
ResourceRegistry.groupId |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
BlockingResource.getGroupId() |
CPGroupId |
ResourceRegistry.getGroupId() |
Modifier and Type | Method and Description |
---|---|
protected Set<CPGroupId> |
AbstractBlockingService.getGroupIdSet() |
protected Map<CPGroupId,Object> |
AbstractBlockingService.getSnapshotMap(int partitionId) |
Modifier and Type | Method and Description |
---|---|
protected abstract RR |
AbstractBlockingService.createNewRegistry(CPGroupId groupId)
Creates a registry for the given Raft group.
|
protected abstract R |
ResourceRegistry.createNewResource(CPGroupId groupId,
String name) |
boolean |
AbstractBlockingService.destroyRaftObject(CPGroupId groupId,
String name) |
void |
AbstractBlockingService.expireWaitKeys(CPGroupId groupId,
Collection<BiTuple<String,UUID>> keys) |
Collection<Long> |
AbstractBlockingService.getAttachedSessions(CPGroupId groupId) |
Collection<BiTuple<Address,Long>> |
AbstractBlockingService.getLiveOperations(CPGroupId groupId) |
protected RR |
AbstractBlockingService.getOrInitRegistry(CPGroupId groupId) |
RR |
AbstractBlockingService.getRegistryOrNull(CPGroupId groupId) |
protected void |
AbstractBlockingService.heartbeatSession(CPGroupId groupId,
long sessionId) |
protected void |
AbstractBlockingService.notifyWaitKeys(CPGroupId groupId,
String name,
Collection<W> keys,
Object result) |
void |
AbstractBlockingService.onRaftGroupDestroyed(CPGroupId groupId) |
void |
AbstractBlockingService.onRaftNodeSteppedDown(CPGroupId groupId) |
void |
AbstractBlockingService.onSessionClose(CPGroupId groupId,
long sessionId) |
void |
AbstractBlockingService.restoreSnapshot(CPGroupId groupId,
long commitIndex,
RR registry) |
protected void |
AbstractBlockingService.scheduleTimeout(CPGroupId groupId,
String name,
UUID invocationUid,
long timeoutMs) |
RR |
AbstractBlockingService.takeSnapshot(CPGroupId groupId,
long commitIndex) |
Constructor and Description |
---|
BlockingResource(CPGroupId groupId,
String name) |
ResourceRegistry(CPGroupId groupId) |
Modifier and Type | Method and Description |
---|---|
Object |
ExpireWaitKeysOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
Object |
DestroyRaftObjectOp.run(CPGroupId groupId,
long commitIndex) |
Constructor and Description |
---|
ChangeRaftGroupMembershipOp(CPGroupId groupId,
long membersCommitIndex,
RaftEndpoint member,
MembershipChangeMode membershipChangeMode) |
DefaultRaftReplicateOp(CPGroupId groupId,
RaftOp op) |
DestroyRaftGroupOp(CPGroupId groupId) |
RaftQueryOp(CPGroupId groupId,
RaftOp raftOp,
QueryPolicy queryPolicy) |
TransferLeadershipOp(CPGroupId groupId,
CPMember destination) |
Modifier and Type | Field and Description |
---|---|
protected CPGroupId |
AsyncRaftOp.groupId |
Constructor and Description |
---|
AppendFailureResponseOp(CPGroupId groupId,
AppendFailureResponse appendResponse) |
AppendRequestOp(CPGroupId groupId,
AppendRequest appendRequest) |
AppendSuccessResponseOp(CPGroupId groupId,
AppendSuccessResponse appendResponse) |
InstallSnapshotOp(CPGroupId groupId,
InstallSnapshot installSnapshot) |
PreVoteRequestOp(CPGroupId groupId,
PreVoteRequest voteRequest) |
PreVoteResponseOp(CPGroupId groupId,
PreVoteResponse voteResponse) |
TriggerLeaderElectionOp(CPGroupId groupId,
TriggerLeaderElection request) |
VoteRequestOp(CPGroupId groupId,
VoteRequest voteRequest) |
VoteResponseOp(CPGroupId groupId,
VoteResponse voteResponse) |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
AbstractUnsafeRaftOp.getGroupId() |
Constructor and Description |
---|
UnsafeRaftBackupOp(CPGroupId groupId,
RaftOp op) |
UnsafeRaftQueryOp(CPGroupId groupId,
RaftOp op) |
UnsafeRaftReplicateOp(CPGroupId groupId,
RaftOp op) |
Constructor and Description |
---|
UnsafeSnapshotReplicationOp(Map<CPGroupId,Object> snapshots) |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotAwareService.restoreSnapshot(CPGroupId groupId,
long commitIndex,
T snapshot)
Restores the snapshot for specified
CPGroupId . |
T |
SnapshotAwareService.takeSnapshot(CPGroupId groupId,
long commitIndex)
Creates a snapshot for specified
CPGroupId . |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
RaftNodeImpl.getGroupId() |
CPGroupId |
RaftNode.getGroupId()
Returns the groupId which this node belongs to.
|
Modifier and Type | Method and Description |
---|---|
static RaftNodeImpl |
RaftNodeImpl.newRaftNode(CPGroupId groupId,
RaftEndpoint localMember,
Collection<RaftEndpoint> members,
RaftAlgorithmConfig config,
RaftIntegration integration)
Creates a new Raft node with an empty initial state.
|
static RaftNodeImpl |
RaftNodeImpl.newRaftNode(CPGroupId groupId,
RaftEndpoint localMember,
Collection<RaftEndpoint> members,
RaftAlgorithmConfig config,
RaftIntegration integration,
RaftStateStore raftStateStore)
Creates a new Raft node with an empty initial state
and a
RaftStateStore to persist Raft state changes |
static RaftNodeImpl |
RaftNodeImpl.restoreRaftNode(CPGroupId groupId,
RestoredRaftState restoredState,
RaftAlgorithmConfig config,
RaftIntegration integration)
Creates a new Raft node with restored Raft state
|
static RaftNodeImpl |
RaftNodeImpl.restoreRaftNode(CPGroupId groupId,
RestoredRaftState restoredState,
RaftAlgorithmConfig config,
RaftIntegration integration,
RaftStateStore raftStateStore)
Creates a new Raft node with restored Raft state
and a
RaftStateStore to persist Raft state changes |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
RaftState.groupId() |
Modifier and Type | Method and Description |
---|---|
static RaftState |
RaftState.newRaftState(CPGroupId groupId,
RaftEndpoint localEndpoint,
Collection<RaftEndpoint> endpoints,
int logCapacity) |
static RaftState |
RaftState.newRaftState(CPGroupId groupId,
RaftEndpoint localEndpoint,
Collection<RaftEndpoint> endpoints,
int logCapacity,
RaftStateStore stateStore) |
static RaftState |
RaftState.restoreRaftState(CPGroupId groupId,
RestoredRaftState restoredState,
int logCapacity) |
static RaftState |
RaftState.restoreRaftState(CPGroupId groupId,
RestoredRaftState restoredState,
int logCapacity,
RaftStateStore stateStore) |
Modifier and Type | Method and Description |
---|---|
Object |
NotifyTermChangeOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GetInitialRaftGroupMembersIfCurrentGroupMemberOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
Object |
MetadataRaftGroupOp.run(CPGroupId groupId,
long commitIndex) |
Constructor and Description |
---|
CreateRaftNodeOp(CPGroupId groupId,
Collection<RaftEndpoint> initialMembers) |
GetRaftGroupOp(CPGroupId targetGroupId) |
TriggerDestroyRaftGroupOp(CPGroupId targetGroupId) |
Constructor and Description |
---|
CompleteDestroyRaftGroupsOp(Set<CPGroupId> groupIds) |
CompleteRaftGroupMembershipChangesOp(Map<CPGroupId,BiTuple<Long,Long>> changedGroups) |
DestroyRaftNodesOp(Collection<CPGroupId> groupIds) |
Modifier and Type | Method and Description |
---|---|
Object |
RestoreSnapshotOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
protected Map<CPGroupId,Object> |
RaftSessionService.getSnapshotMap(int partitionId) |
Modifier and Type | Method and Description |
---|---|
void |
RaftSessionService.closeInactiveSessions(CPGroupId groupId,
Collection<Long> inactiveSessions) |
boolean |
RaftSessionService.closeSession(CPGroupId groupId,
long sessionId) |
SessionResponse |
RaftSessionService.createNewSession(CPGroupId groupId,
Address endpoint,
String endpointName,
CPSession.CPSessionOwnerType endpointType,
long creationTime) |
void |
RaftSessionService.expireSessions(CPGroupId groupId,
Collection<BiTuple<Long,Long>> sessionsToExpire) |
long |
RaftSessionService.generateThreadId(CPGroupId groupId) |
InternalCompletableFuture<Collection<CPSession>> |
RaftSessionService.getAllSessions(CPGroupId groupId) |
Collection<Long> |
SessionAwareService.getAttachedSessions(CPGroupId groupId)
Returns a collection of session ids that this service has attached some
resources.
|
Collection<CPSession> |
RaftSessionService.getSessionsLocally(CPGroupId groupId) |
void |
RaftSessionService.heartbeat(CPGroupId groupId,
long sessionId) |
void |
SessionAccessor.heartbeat(CPGroupId groupId,
long sessionId)
Performs a heartbeat for the given session id in the Raft group.
|
boolean |
RaftSessionService.isActive(CPGroupId groupId,
long sessionId) |
boolean |
SessionAccessor.isActive(CPGroupId groupId,
long sessionId)
Checks if there is an active session with the given id in the Raft group
|
void |
RaftSessionService.onNewTermCommit(CPGroupId groupId,
long commitIndex) |
void |
RaftSessionService.onRaftGroupDestroyed(CPGroupId groupId) |
void |
RaftSessionService.onRaftNodeSteppedDown(CPGroupId groupId) |
void |
SessionAwareService.onSessionClose(CPGroupId groupId,
long sessionId)
Called when a session is closed.
|
void |
RaftSessionService.restoreSnapshot(CPGroupId groupId,
long commitIndex,
com.hazelcast.cp.internal.session.RaftSessionRegistry registry) |
com.hazelcast.cp.internal.session.RaftSessionRegistry |
RaftSessionService.takeSnapshot(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
Object |
CloseSessionOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GetSessionsOp.run(CPGroupId groupId,
long commitIndex) |
Object |
HeartbeatSessionOp.run(CPGroupId groupId,
long commitIndex) |
Object |
ExpireSessionsOp.run(CPGroupId groupId,
long commitIndex) |
Object |
GenerateThreadIdOp.run(CPGroupId groupId,
long commitIndex) |
Object |
CreateSessionOp.run(CPGroupId groupId,
long commitIndex) |
Object |
CloseInactiveSessionsOp.run(CPGroupId groupId,
long commitIndex) |
Modifier and Type | Method and Description |
---|---|
CPGroupId |
FencedLock.getGroupId()
Returns id of the CP group that runs this
FencedLock instance |
Constructor and Description |
---|
RaftInvocation(com.hazelcast.spi.impl.operationservice.impl.Invocation.Context context,
RaftInvocationContext raftInvocationContext,
CPGroupId groupId,
Operation op,
int retryCount,
long retryPauseMillis,
long callTimeoutMillis) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.