public class NoopInternalHotRestartService extends Object implements InternalHotRestartService
Constructor and Description |
---|
NoopInternalHotRestartService() |
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.
|
public boolean triggerForceStart()
InternalHotRestartService
triggerForceStart
in interface InternalHotRestartService
public boolean triggerPartialStart()
InternalHotRestartService
HotRestartPersistenceConfig.clusterDataRecoveryPolicy
is set accordingly.triggerPartialStart
in interface InternalHotRestartService
public boolean isMemberExcluded(Address memberAddress, String memberUuid)
InternalHotRestartService
isMemberExcluded
in interface InternalHotRestartService
memberAddress
- address of the member to checkmemberUuid
- UUID of the member to checkpublic Set<String> getExcludedMemberUuids()
InternalHotRestartService
getExcludedMemberUuids
in interface InternalHotRestartService
public void notifyExcludedMember(Address memberAddress)
InternalHotRestartService
notifyExcludedMember
in interface InternalHotRestartService
memberAddress
- address of the member to notifypublic void handleExcludedMemberUuids(Address sender, Set<String> excludedMemberUuids)
InternalHotRestartService
handleExcludedMemberUuids
in interface InternalHotRestartService
sender
- the member that has sent the excluded members setexcludedMemberUuids
- UUIDs of the members that have been excluded during the cluster startpublic com.hazelcast.internal.management.dto.ClusterHotRestartStatusDTO getCurrentClusterHotRestartStatus()
InternalHotRestartService
getCurrentClusterHotRestartStatus
in interface InternalHotRestartService
public void resetHotRestartData()
InternalHotRestartService
resetHotRestartData
in interface InternalHotRestartService
public void waitPartitionReplicaSyncOnCluster(long timeout, TimeUnit unit)
InternalHotRestartService
waitPartitionReplicaSyncOnCluster
in interface InternalHotRestartService
timeout
- timeoutunit
- time unitCopyright © 2018 Hazelcast, Inc.. All rights reserved.