org.apache.ambari.server.agent

Class RecoveryConfigHelper

java.lang.Object

org.apache.ambari.server.agent.RecoveryConfigHelper

public class RecoveryConfigHelper
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	RECOVERY_ENABLED_KEY Recovery related configuration
static String	RECOVERY_LIFETIME_MAX_COUNT_DEFAULT
static String	RECOVERY_LIFETIME_MAX_COUNT_KEY
static String	RECOVERY_MAX_COUNT_DEFAULT
static String	RECOVERY_MAX_COUNT_KEY
static String	RECOVERY_RETRY_GAP_DEFAULT
static String	RECOVERY_RETRY_GAP_KEY
static String	RECOVERY_TYPE_DEFAULT
static String	RECOVERY_TYPE_KEY
static String	RECOVERY_WINDOW_IN_MIN_DEFAULT
static String	RECOVERY_WINDOW_IN_MIN_KEY

Constructor Summary

Constructors

Constructor and Description
RecoveryConfigHelper(AmbariEventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
RecoveryConfig	getDefaultRecoveryConfig()
RecoveryConfig	getRecoveryConfig(String clusterName, String hostname)
void	handleClusterEnvConfigChangedEvent(ClusterConfigChangedEvent event) Cluster-env configuration changed.
void	handleMaintenanceModeEvent(MaintenanceModeEvent event) Maintenance mode of a host, service or service component host changed.
void	handleServiceComponentInstalledEvent(ServiceComponentInstalledEvent event) A service component was installed on a host.
void	handleServiceComponentRecoveryChangedEvent(ServiceComponentRecoveryChangedEvent event) Recovery enabled was turned on or off.
void	handleServiceComponentUninstalledEvent(ServiceComponentUninstalledEvent event) A service component was uninstalled from a host.
boolean	isConfigStale(String clusterName, String hostname, long recoveryTimestamp) Computes if the recovery configuration was updated since the last time it was sent to the agent.

Methods inherited from class java.lang.Object

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

Field Detail

RECOVERY_ENABLED_KEY

public static final String RECOVERY_ENABLED_KEY

Recovery related configuration

See Also:

Constant Field Values

RECOVERY_TYPE_KEY

public static final String RECOVERY_TYPE_KEY

See Also:

Constant Field Values

RECOVERY_TYPE_DEFAULT

public static final String RECOVERY_TYPE_DEFAULT

See Also:

Constant Field Values

RECOVERY_LIFETIME_MAX_COUNT_KEY

public static final String RECOVERY_LIFETIME_MAX_COUNT_KEY

See Also:

Constant Field Values

RECOVERY_LIFETIME_MAX_COUNT_DEFAULT

public static final String RECOVERY_LIFETIME_MAX_COUNT_DEFAULT

See Also:

Constant Field Values

RECOVERY_MAX_COUNT_KEY

public static final String RECOVERY_MAX_COUNT_KEY

See Also:

Constant Field Values

RECOVERY_MAX_COUNT_DEFAULT

public static final String RECOVERY_MAX_COUNT_DEFAULT

See Also:

Constant Field Values

RECOVERY_WINDOW_IN_MIN_KEY

public static final String RECOVERY_WINDOW_IN_MIN_KEY

See Also:

Constant Field Values

RECOVERY_WINDOW_IN_MIN_DEFAULT

public static final String RECOVERY_WINDOW_IN_MIN_DEFAULT

See Also:

Constant Field Values

RECOVERY_RETRY_GAP_KEY

public static final String RECOVERY_RETRY_GAP_KEY

See Also:

Constant Field Values

RECOVERY_RETRY_GAP_DEFAULT

public static final String RECOVERY_RETRY_GAP_DEFAULT

See Also:

Constant Field Values

Constructor Detail

RecoveryConfigHelper

@Inject
public RecoveryConfigHelper(AmbariEventPublisher eventPublisher)

Method Detail

getDefaultRecoveryConfig

public RecoveryConfig getDefaultRecoveryConfig()
                                        throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getRecoveryConfig

public RecoveryConfig getRecoveryConfig(String clusterName,
                                        String hostname)
                                 throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

isConfigStale

public boolean isConfigStale(String clusterName,
                             String hostname,
                             long recoveryTimestamp)

Computes if the recovery configuration was updated since the last time it was sent to the agent.

Parameters:

clusterName - - Name of the cluster which the host belongs to.

hostname - - Host name from agent.

recoveryTimestamp - - Time when the recovery configuration was last sent to the agent. Agent stores this value and sends it during each heartbeat. -1 if agent was restarted or configuration was not sent to the agent since it started.

Returns:

handleMaintenanceModeEvent

public void handleMaintenanceModeEvent(MaintenanceModeEvent event)
                                throws org.apache.ambari.server.AmbariException

Maintenance mode of a host, service or service component host changed.

Parameters:

event -

Throws:

org.apache.ambari.server.AmbariException

handleServiceComponentInstalledEvent

public void handleServiceComponentInstalledEvent(ServiceComponentInstalledEvent event)
                                          throws org.apache.ambari.server.AmbariException

A service component was installed on a host.

Parameters:

event -

Throws:

org.apache.ambari.server.AmbariException

handleServiceComponentUninstalledEvent

public void handleServiceComponentUninstalledEvent(ServiceComponentUninstalledEvent event)
                                            throws org.apache.ambari.server.AmbariException

A service component was uninstalled from a host.

Parameters:

event -

Throws:

org.apache.ambari.server.AmbariException

handleServiceComponentRecoveryChangedEvent

public void handleServiceComponentRecoveryChangedEvent(ServiceComponentRecoveryChangedEvent event)

Recovery enabled was turned on or off.

Parameters:

event -

handleClusterEnvConfigChangedEvent

public void handleClusterEnvConfigChangedEvent(ClusterConfigChangedEvent event)

Cluster-env configuration changed.

Parameters:

event -