com.hazelcast.cp.internal

Class MetadataRaftGroupManager

java.lang.Object

com.hazelcast.cp.internal.MetadataRaftGroupManager

All Implemented Interfaces:

SnapshotAwareService<MetadataRaftGroupSnapshot>

public class MetadataRaftGroupManager
extends Object
implements SnapshotAwareService<MetadataRaftGroupSnapshot>

Maintains the CP subsystem metadata, such as CP groups, active CP members, leaving and joining CP members, etc.

Field Summary

Fields

Modifier and Type	Field and Description
static RaftGroupId	INITIAL_METADATA_GROUP_ID

Method Summary

Modifier and Type	Method and Description
boolean	addMember(long commitIndex, CPMemberInfo member) this method is idempotent
void	checkMetadataGroupInitSuccessful()
void	completeDestroyRaftGroups(Set<CPGroupId> groupIds)
MembershipChangeSchedule	completeRaftGroupMembershipChanges(long commitIndex, Map<CPGroupId,Tuple2<Long,Long>> changedGroups)
CPGroupId	createRaftGroup(String groupName, Collection<CPMemberInfo> members, long commitIndex)
void	disableDiscovery()
void	forceDestroyRaftGroup(String groupName)
CPGroupInfo	getActiveGroup(String groupName)
Collection<CPGroupId>	getActiveGroupIds()
Collection<CPMemberInfo>	getActiveMembers()
Collection<CPGroupId>	getDestroyingGroupIds()
CPGroupInfo	getGroup(CPGroupId groupId)
Collection<CPGroupId>	getGroupIds()
MembershipChangeSchedule	getMembershipChangeSchedule()
RaftGroupId	getMetadataGroupId()
void	handleMetadataGroupId(RaftGroupId newMetadataGroupId)
boolean	initMetadataGroup(long commitIndex, CPMemberInfo callerCPMember, List<CPMemberInfo> discoveredCPMembers, long expectedGroupIdSeed)
boolean	removeMember(long commitIndex, CPMemberInfo leavingMember) this method is idempotent
void	restoreSnapshot(CPGroupId groupId, long commitIndex, MetadataRaftGroupSnapshot snapshot) Restores the snapshot for specified CPGroupId.
MetadataRaftGroupSnapshot	takeSnapshot(CPGroupId groupId, long commitIndex) Creates a snapshot for specified CPGroupId.
void	triggerDestroyRaftGroup(CPGroupId groupId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INITIAL_METADATA_GROUP_ID

public static final RaftGroupId INITIAL_METADATA_GROUP_ID

Method Detail

takeSnapshot

public MetadataRaftGroupSnapshot takeSnapshot(CPGroupId groupId,
                                              long commitIndex)

Description copied from interface: SnapshotAwareService

Creates a snapshot for specified CPGroupId. The snapshot object returned from this method will be stored among the Raft log and it can be sent to other Raft nodes anytime. Therefore, this method must not return a snapshot object that can mutate after the takeSnapshot() call.

Specified by:

takeSnapshot in interface SnapshotAwareService<MetadataRaftGroupSnapshot>

Parameters:

groupId - CPGroupId which is snapshot requested for

commitIndex - commitIndex of the taken snapshot

Returns:

snapshot for specified CPGroupId.

restoreSnapshot

public void restoreSnapshot(CPGroupId groupId,
                            long commitIndex,
                            MetadataRaftGroupSnapshot snapshot)

Description copied from interface: SnapshotAwareService

Restores the snapshot for specified CPGroupId.

Specified by:

restoreSnapshot in interface SnapshotAwareService<MetadataRaftGroupSnapshot>

Parameters:

groupId - CPGroupId of the snapshot to be restored

commitIndex - commitIndex of the restored snapshot

snapshot - snapshot for specified CPGroupId

getMetadataGroupId

public RaftGroupId getMetadataGroupId()

getGroupIds

public Collection<CPGroupId> getGroupIds()

getActiveGroupIds

public Collection<CPGroupId> getActiveGroupIds()

getGroup

public CPGroupInfo getGroup(CPGroupId groupId)

getActiveGroup

public CPGroupInfo getActiveGroup(String groupName)

initMetadataGroup

public boolean initMetadataGroup(long commitIndex,
                                 CPMemberInfo callerCPMember,
                                 List<CPMemberInfo> discoveredCPMembers,
                                 long expectedGroupIdSeed)

createRaftGroup

public CPGroupId createRaftGroup(String groupName,
                                 Collection<CPMemberInfo> members,
                                 long commitIndex)

triggerDestroyRaftGroup

public void triggerDestroyRaftGroup(CPGroupId groupId)

completeDestroyRaftGroups

public void completeDestroyRaftGroups(Set<CPGroupId> groupIds)

forceDestroyRaftGroup

public void forceDestroyRaftGroup(String groupName)

removeMember

public boolean removeMember(long commitIndex,
                            CPMemberInfo leavingMember)

this method is idempotent

completeRaftGroupMembershipChanges

public MembershipChangeSchedule completeRaftGroupMembershipChanges(long commitIndex,
                                                                   Map<CPGroupId,Tuple2<Long,Long>> changedGroups)

getActiveMembers

public Collection<CPMemberInfo> getActiveMembers()

handleMetadataGroupId

public void handleMetadataGroupId(RaftGroupId newMetadataGroupId)

getDestroyingGroupIds

public Collection<CPGroupId> getDestroyingGroupIds()

getMembershipChangeSchedule

public MembershipChangeSchedule getMembershipChangeSchedule()

addMember

public boolean addMember(long commitIndex,
                         CPMemberInfo member)

this method is idempotent

checkMetadataGroupInitSuccessful

public void checkMetadataGroupInitSuccessful()

disableDiscovery

public void disableDiscovery()