alluxio.master

Class DefaultSafeModeManager

java.lang.Object

alluxio.master.DefaultSafeModeManager

All Implemented Interfaces:

SafeModeManager

public class DefaultSafeModeManager
extends Object
implements SafeModeManager

Manages safe mode state for Alluxio master.

Constructor Summary

Constructors

Constructor and Description
DefaultSafeModeManager() Creates DefaultSafeModeManager with default clock.
DefaultSafeModeManager(java.time.Clock clock) Creates DefaultSafeModeManager with given clock.

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSafeModeManager

public DefaultSafeModeManager()

Creates DefaultSafeModeManager with default clock.

DefaultSafeModeManager

public DefaultSafeModeManager(java.time.Clock clock)

Creates DefaultSafeModeManager with given clock.

Parameters:

clock - a Clock for calculating elapsed time

Method Detail

notifyPrimaryMasterStarted

public void notifyPrimaryMasterStarted()

Description copied from interface: SafeModeManager

Notifies SafeModeManager that the primary master is started.

Specified by:

notifyPrimaryMasterStarted in interface SafeModeManager

notifyRpcServerStarted

public void notifyRpcServerStarted()

Description copied from interface: SafeModeManager

Notifies SafeModeManager that the RPC server is started.

Specified by:

notifyRpcServerStarted in interface SafeModeManager

isInSafeMode

public boolean isInSafeMode()

Specified by:

isInSafeMode in interface SafeModeManager

Returns:

whether master is in safe mode