org.apache.ambari.server.agent

Class HeartBeatResponse

java.lang.Object

org.apache.ambari.server.agent.stomp.StompResponse

org.apache.ambari.server.agent.HeartBeatResponse

public class HeartBeatResponse
extends StompResponse

Controller to Agent response data model.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ambari.server.agent.stomp.StompResponse

StompResponse.StompResponseStatus

Constructor Summary

Constructors

Constructor and Description
HeartBeatResponse()

Method Summary

Modifier and Type	Method and Description
void	addAlertDefinitionCommand(AlertDefinitionCommand command)
void	addAlertExecutionCommand(AlertExecutionCommand command)
void	addCancelCommand(CancelCommand cancelCmd)
void	addExecutionCommand(ExecutionCommand execCmd)
void	addStatusCommand(StatusCommand statCmd)
List<AlertDefinitionCommand>	getAlertDefinitionCommands() Gets the alert definition commands that contain the alert definitions for each cluster that the host is a member of.
List<CancelCommand>	getCancelCommands()
List<ExecutionCommand>	getExecutionCommands()
RecoveryConfig	getRecoveryConfig() Get the recovery configuration settings for this host.
RegistrationCommand	getRegistrationCommand()
long	getResponseId()
List<StatusCommand>	getStatusCommands()
boolean	hasMappedComponents()
boolean	hasPendingTasks()
Boolean	isRestartAgent()
void	setAlertDefinitionCommands(List<AlertDefinitionCommand> commands) Sets the alert definition commands that contain the alert definitions for each cluster that the host is a member of.
void	setCancelCommands(List<CancelCommand> cancelCommands)
void	setClusterSize(int clusterSize)
void	setExecutionCommands(List<ExecutionCommand> executionCommands)
void	setHasMappedComponents(boolean hasMappedComponents)
void	setHasPendingTasks(boolean hasPendingTasks)
void	setRecoveryConfig(RecoveryConfig recoveryConfig) Set the recovery configuration.
void	setRegistrationCommand(RegistrationCommand registrationCommand)
void	setResponseId(long responseId)
void	setRestartAgent(Boolean restartAgent)
void	setStatusCommands(List<StatusCommand> statusCommands)
String	toString()

Methods inherited from class org.apache.ambari.server.agent.stomp.StompResponse

getStatus, setStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

HeartBeatResponse

public HeartBeatResponse()

Method Detail

getResponseId

public long getResponseId()

setResponseId

public void setResponseId(long responseId)

getExecutionCommands

public List<ExecutionCommand> getExecutionCommands()

setExecutionCommands

public void setExecutionCommands(List<ExecutionCommand> executionCommands)

getStatusCommands

public List<StatusCommand> getStatusCommands()

setStatusCommands

public void setStatusCommands(List<StatusCommand> statusCommands)

getCancelCommands

public List<CancelCommand> getCancelCommands()

setCancelCommands

public void setCancelCommands(List<CancelCommand> cancelCommands)

getRegistrationCommand

public RegistrationCommand getRegistrationCommand()

setRegistrationCommand

public void setRegistrationCommand(RegistrationCommand registrationCommand)

getRecoveryConfig

public RecoveryConfig getRecoveryConfig()

Get the recovery configuration settings for this host. The configuration is set whenever any value changes. The agent uses this information to update the values on it's side.

Returns:

Null if nothing changed since the last update, else updated configuration.

setRecoveryConfig

public void setRecoveryConfig(RecoveryConfig recoveryConfig)

Set the recovery configuration. Set only when one or more recovery values change. This is to avoid sending the configuration to the agent during every heartbeat.

Parameters:

recoveryConfig -

getAlertDefinitionCommands

public List<AlertDefinitionCommand> getAlertDefinitionCommands()

Gets the alert definition commands that contain the alert definitions for each cluster that the host is a member of.

setAlertDefinitionCommands

public void setAlertDefinitionCommands(List<AlertDefinitionCommand> commands)

Sets the alert definition commands that contain the alert definitions for each cluster that the host is a member of.

Parameters:

commands - the commands, or null for none.

isRestartAgent

public Boolean isRestartAgent()

setRestartAgent

public void setRestartAgent(Boolean restartAgent)

hasMappedComponents

public boolean hasMappedComponents()

setHasMappedComponents

public void setHasMappedComponents(boolean hasMappedComponents)

hasPendingTasks

public boolean hasPendingTasks()

setHasPendingTasks

public void setHasPendingTasks(boolean hasPendingTasks)

addExecutionCommand

public void addExecutionCommand(ExecutionCommand execCmd)

addStatusCommand

public void addStatusCommand(StatusCommand statCmd)

addCancelCommand

public void addCancelCommand(CancelCommand cancelCmd)

addAlertDefinitionCommand

public void addAlertDefinitionCommand(AlertDefinitionCommand command)

addAlertExecutionCommand

public void addAlertExecutionCommand(AlertExecutionCommand command)

setClusterSize

public void setClusterSize(int clusterSize)

toString

public String toString()

Overrides:

toString in class Object