public interface InternalHotRestartService
Modifier and Type | Method and Description |
---|---|
void |
forceStartBeforeJoin()
Executes force-start process, resets local hot restart data and member gets a new UUID.
|
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 |
isEnabled()
Returns whether hot-restart is enabled or not.
|
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 |
resetService(boolean isAfterJoin)
Resets local service data, removes hot restart directories and recreates them.
|
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 isEnabled()
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 startClusterHotRestartStatusDTO getCurrentClusterHotRestartStatus()
void resetService(boolean isAfterJoin)
isAfterJoin
- true if this is called after node joins the cluster, false otherwisevoid forceStartBeforeJoin()
If the local node has already completed the start process or it isn't excluded in cluster start, this method fails with an exception.
void waitPartitionReplicaSyncOnCluster(long timeout, TimeUnit unit)
timeout
- timeoutunit
- time unitIllegalStateException
- when timeout happens or a member leaves the cluster while waitingCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.