Package | Description |
---|---|
com.hazelcast.cp.internal |
Contains implementation of CP Subsystem
|
com.hazelcast.cp.internal.raftop.metadata |
Contains operations that are used in the Metadata CP group
|
com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
com.hazelcast.spi.impl.operationservice.InternalOperationService implementation. |
Modifier and Type | Method and Description |
---|---|
CPMemberInfo |
RaftInvocationManager.getCPMember(RaftEndpoint endpoint) |
CPMemberInfo |
RaftService.getLocalCPMember() |
Modifier and Type | Method and Description |
---|---|
Collection<CPMemberInfo> |
MetadataRaftGroupManager.getActiveMembers() |
List<CPMemberInfo> |
MetadataRaftGroupSnapshot.getInitialCPMembers() |
Set<CPMemberInfo> |
MetadataRaftGroupSnapshot.getInitializedCPMembers() |
Collection<CPMemberInfo> |
MetadataRaftGroupSnapshot.getMembers() |
Modifier and Type | Method and Description |
---|---|
boolean |
MetadataRaftGroupManager.addMember(long commitIndex,
CPMemberInfo member)
this method is idempotent
|
boolean |
MetadataRaftGroupManager.initMetadataGroup(long commitIndex,
CPMemberInfo callerCPMember,
List<CPMemberInfo> discoveredCPMembers,
long expectedGroupIdSeed) |
boolean |
MetadataRaftGroupManager.removeMember(long commitIndex,
CPMemberInfo leavingMember)
this method is idempotent
|
void |
MetadataRaftGroupManager.restoreLocalCPMember(CPMemberInfo member) |
InternalCompletableFuture |
RaftService.transferLeadership(CPGroupId groupId,
CPMemberInfo destination) |
void |
MetadataRaftGroupManager.verifyRestartedMember(long commitIndex,
CPMemberInfo member) |
Modifier and Type | Method and Description |
---|---|
void |
RaftService.handleActiveCPMembers(RaftGroupId receivedMetadataGroupId,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
boolean |
MetadataRaftGroupManager.initMetadataGroup(long commitIndex,
CPMemberInfo callerCPMember,
List<CPMemberInfo> discoveredCPMembers,
long expectedGroupIdSeed) |
void |
MetadataRaftGroupSnapshot.setInitialCPMembers(List<CPMemberInfo> initialCPMembers) |
void |
MetadataRaftGroupSnapshot.setInitializedCPMembers(Collection<CPMemberInfo> initializedCPMembers) |
void |
MetadataRaftGroupSnapshot.setMembers(Collection<CPMemberInfo> members) |
boolean |
RaftService.updateInvocationManagerMembers(long groupIdSeed,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
Modifier and Type | Method and Description |
---|---|
CPMemberInfo |
RemoveCPMemberOp.getMember() |
CPMemberInfo |
AddCPMemberOp.getMember() |
Modifier and Type | Method and Description |
---|---|
List<CPMemberInfo> |
InitMetadataRaftGroupOp.getDiscoveredCPMembers() |
Constructor and Description |
---|
AddCPMemberOp(CPMemberInfo member) |
InitMetadataRaftGroupOp(CPMemberInfo callerCPMember,
List<CPMemberInfo> discoveredCPMembers,
long groupIdSeed) |
RemoveCPMemberOp(CPMemberInfo member) |
Constructor and Description |
---|
InitMetadataRaftGroupOp(CPMemberInfo callerCPMember,
List<CPMemberInfo> discoveredCPMembers,
long groupIdSeed) |
PublishActiveCPMembersOp(RaftGroupId metadataGroupId,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
Modifier and Type | Method and Description |
---|---|
CPMemberInfo |
RaftInvocationContext.getCPMember(UUID memberUid) |
Modifier and Type | Method and Description |
---|---|
void |
RaftInvocationContext.updateMember(CPMemberInfo member) |
Modifier and Type | Method and Description |
---|---|
boolean |
RaftInvocationContext.setMembers(long groupIdSeed,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.