public interface InternalHotRestartService
Modifier and Type | Method and Description |
---|---|
com.hazelcast.internal.management.dto.ClusterHotRestartStatusDTO |
getCurrentClusterHotRestartStatus()
Returns latest Hot Restart status as Management Center DTO.
|
Set<String> |
getExcludedMemberUuids()
Returns UUIDs of the members that have been excluded during the cluster start.
|
void |
handleExcludedMemberUuids(Address sender,
Set<String> excludedMemberUuids)
Handles the UUID set of excluded members only if this member is also excluded, and triggers the member force start process.
|
boolean |
isMemberExcluded(Address memberAddress,
String memberUuid)
Checks if the given member has been excluded during the cluster start or not.
|
void |
notifyExcludedMember(Address memberAddress)
Notifies the excluded member and triggers the member force start process.
|
void |
resetHotRestartData()
Resets local hot restart data and gets a new UUID, if the local node hasn't completed the start process and
it is excluded in cluster start.
|
boolean |
triggerForceStart()
Forces node to start by skipping hot-restart completely and removing all hot-restart data
even if node is still on validation phase or loading hot-restart data.
|
boolean |
triggerPartialStart()
Triggers partial start if the cluster cannot be started with full recovery and
HotRestartPersistenceConfig.clusterDataRecoveryPolicy is set accordingly. |
void |
waitPartitionReplicaSyncOnCluster(long timeout,
TimeUnit unit)
Waits until partition replicas (primaries and backups) get in sync.
|
boolean triggerForceStart()
boolean triggerPartialStart()
HotRestartPersistenceConfig.clusterDataRecoveryPolicy
is set accordingly.boolean isMemberExcluded(Address memberAddress, String memberUuid)
memberAddress
- address of the member to checkmemberUuid
- UUID of the member to checkSet<String> getExcludedMemberUuids()
void notifyExcludedMember(Address memberAddress)
memberAddress
- address of the member to notifyvoid handleExcludedMemberUuids(Address sender, Set<String> excludedMemberUuids)
sender
- the member that has sent the excluded members setexcludedMemberUuids
- UUIDs of the members that have been excluded during the cluster startcom.hazelcast.internal.management.dto.ClusterHotRestartStatusDTO getCurrentClusterHotRestartStatus()
void resetHotRestartData()
void waitPartitionReplicaSyncOnCluster(long timeout, TimeUnit unit)
timeout
- timeoutunit
- time unitIllegalStateException
- when timeout happens or a member leaves the cluster while waitingCopyright © 2018 Hazelcast, Inc.. All rights reserved.