org.apache.ambari.server.agent

Class HeartBeatHandler

java.lang.Object

org.apache.ambari.server.agent.HeartBeatHandler

public class HeartBeatHandler
extends Object

This class handles the heartbeats coming from the agent, passes on the information to other modules and processes the queue to send heartbeat response.

Constructor Summary

Constructors

Constructor and Description
HeartBeatHandler(Clusters fsm, ActionManager am, Encryptor<AgentConfigsUpdateEvent> encryptor, com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
HeartBeatResponse	createRegisterCommand()
protected HeartBeatResponse	createRestartCommand(Long currentResponseId)
HeartbeatProcessor	getHeartbeatProcessor()
String	getOsType(String os, String osRelease)
void	handleCommandReportStatus(List<CommandReport> reports, String hostname)
void	handleComponentReportStatus(List<ComponentStatus> componentStatuses, String hostname)
ComponentsResponse	handleComponents(String clusterName) Response contains information about HDP Stack in use
void	handleComponentVersionReports(ComponentVersionReports componentVersionReports, String hostname)
HeartBeatResponse	handleHeartBeat(HeartBeat heartbeat)
void	handleHostReportStatus(HostStatusReport hostStatusReport, String hostname)
RegistrationResponse	handleRegistration(Register register)
protected void	processRecoveryReport(RecoveryReport recoveryReport, String hostname)
void	setHeartbeatProcessor(HeartbeatProcessor heartbeatProcessor)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

HeartBeatHandler

@Inject
public HeartBeatHandler(Clusters fsm,
                                ActionManager am,
                                @Named(value="AgentConfigEncryptor")
                                Encryptor<AgentConfigsUpdateEvent> encryptor,
                                com.google.inject.Injector injector)

Method Detail

start

public void start()

setHeartbeatProcessor

public void setHeartbeatProcessor(HeartbeatProcessor heartbeatProcessor)

getHeartbeatProcessor

public HeartbeatProcessor getHeartbeatProcessor()

handleHeartBeat

public HeartBeatResponse handleHeartBeat(HeartBeat heartbeat)
                                  throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

handleComponentReportStatus

public void handleComponentReportStatus(List<ComponentStatus> componentStatuses,
                                        String hostname)
                                 throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

handleCommandReportStatus

public void handleCommandReportStatus(List<CommandReport> reports,
                                      String hostname)
                               throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

handleHostReportStatus

public void handleHostReportStatus(HostStatusReport hostStatusReport,
                                   String hostname)
                            throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

handleComponentVersionReports

public void handleComponentVersionReports(ComponentVersionReports componentVersionReports,
                                          String hostname)
                                   throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

processRecoveryReport

protected void processRecoveryReport(RecoveryReport recoveryReport,
                                     String hostname)
                              throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getOsType

public String getOsType(String os,
                        String osRelease)

createRegisterCommand

public HeartBeatResponse createRegisterCommand()

createRestartCommand

protected HeartBeatResponse createRestartCommand(Long currentResponseId)

handleRegistration

public RegistrationResponse handleRegistration(Register register)
                                        throws InvalidStateTransitionException,
                                               org.apache.ambari.server.AmbariException

Throws:

InvalidStateTransitionException

org.apache.ambari.server.AmbariException

handleComponents

public ComponentsResponse handleComponents(String clusterName)
                                    throws org.apache.ambari.server.AmbariException

Response contains information about HDP Stack in use

Parameters:

clusterName -

Returns:

@ComponentsResponse

Throws:

org.apache.ambari.server.AmbariException

stop

public void stop()