public class DefaultSafeModeManager extends Object implements SafeModeManager
Constructor and Description |
---|
DefaultSafeModeManager()
Creates
DefaultSafeModeManager with default clock. |
DefaultSafeModeManager(java.time.Clock clock)
Creates
DefaultSafeModeManager with given clock. |
Modifier and Type | Method and Description |
---|---|
boolean |
isInSafeMode() |
void |
notifyPrimaryMasterStarted()
Notifies
SafeModeManager that the primary master is started. |
void |
notifyRpcServerStarted()
Notifies
SafeModeManager that the RPC server is started. |
public DefaultSafeModeManager()
DefaultSafeModeManager
with default clock.public DefaultSafeModeManager(java.time.Clock clock)
DefaultSafeModeManager
with given clock.clock
- a Clock
for calculating elapsed timepublic void notifyPrimaryMasterStarted()
SafeModeManager
SafeModeManager
that the primary master is started.notifyPrimaryMasterStarted
in interface SafeModeManager
public void notifyRpcServerStarted()
SafeModeManager
SafeModeManager
that the RPC server is started.notifyRpcServerStarted
in interface SafeModeManager
public boolean isInSafeMode()
isInSafeMode
in interface SafeModeManager
Copyright © 2023. All Rights Reserved.