Package | Description |
---|---|
com.hazelcast.cp.internal |
Contains implementation of the CP subsystem
|
com.hazelcast.cp.internal.operation |
Contains operations for the Raft Invocation SPI
|
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
InternalOperationService implementation. |
Modifier and Type | Method and Description |
---|---|
CPMemberInfo |
RaftService.getLocalCPMember() |
CPMemberInfo[] |
CPGroupInfo.membersArray() |
Modifier and Type | Method and Description |
---|---|
Collection<CPMemberInfo> |
MetadataRaftGroupManager.getActiveMembers() |
List<CPMemberInfo> |
MetadataRaftGroupSnapshot.getInitialCPMembers() |
Set<CPMemberInfo> |
MetadataRaftGroupSnapshot.getInitializedCPMembers() |
Collection<CPMemberInfo> |
MetadataRaftGroupSnapshot.getMembers() |
Collection<CPMemberInfo> |
CPGroupInfo.memberImpls() |
Modifier and Type | Method and Description |
---|---|
boolean |
MetadataRaftGroupManager.addMember(long commitIndex,
CPMemberInfo member)
this method is idempotent
|
boolean |
CPGroupInfo.applyMembershipChange(CPMemberInfo leaving,
CPMemberInfo joining,
long expectedMembersCommitIndex,
long newMembersCommitIndex) |
boolean |
CPGroupInfo.containsMember(CPMemberInfo member) |
boolean |
MetadataRaftGroupManager.initMetadataGroup(long commitIndex,
CPMemberInfo callerCPMember,
List<CPMemberInfo> discoveredCPMembers,
long expectedGroupIdSeed) |
boolean |
MetadataRaftGroupManager.removeMember(long commitIndex,
CPMemberInfo leavingMember)
this method is idempotent
|
Modifier and Type | Method and Description |
---|---|
CPGroupId |
MetadataRaftGroupManager.createRaftGroup(String groupName,
Collection<CPMemberInfo> members,
long commitIndex) |
void |
RaftService.createRaftNode(CPGroupId groupId,
Collection<CPMemberInfo> members) |
void |
RaftService.handleActiveCPMembers(RaftGroupId latestMetadataGroupId,
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) |
Constructor and Description |
---|
CPGroupInfo(RaftGroupId id,
Collection<CPMemberInfo> members) |
Constructor and Description |
---|
ChangeRaftGroupMembershipOp(CPGroupId groupId,
long membersCommitIndex,
CPMemberInfo member,
MembershipChangeMode membershipChangeMode) |
Constructor and Description |
---|
AddCPMemberOp(CPMemberInfo member) |
InitMetadataRaftGroupOp(CPMemberInfo callerCPMember,
List<CPMemberInfo> discoveredCPMembers,
long groupIdSeed) |
RemoveCPMemberOp(CPMemberInfo member) |
Constructor and Description |
---|
CreateRaftGroupOp(String groupName,
Collection<CPMemberInfo> members) |
CreateRaftNodeOp(CPGroupId groupId,
Collection<CPMemberInfo> initialMembers) |
InitMetadataRaftGroupOp(CPMemberInfo callerCPMember,
List<CPMemberInfo> discoveredCPMembers,
long groupIdSeed) |
PublishActiveCPMembersOp(RaftGroupId metadataGroupId,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
Modifier and Type | Method and Description |
---|---|
void |
RaftInvocationContext.setMembers(long groupIdSeed,
long membersCommitIndex,
Collection<CPMemberInfo> members) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.