org.apache.ambari.server.agent.stomp

Class AlertDefinitionsHolder

java.lang.Object

org.apache.ambari.server.agent.stomp.AgentDataHolder<T>

org.apache.ambari.server.agent.stomp.AgentHostDataHolder<AlertDefinitionsAgentUpdateEvent>

org.apache.ambari.server.agent.stomp.AlertDefinitionsHolder

@Singleton
public class AlertDefinitionsHolder
extends AgentHostDataHolder<AlertDefinitionsAgentUpdateEvent>

Field Summary

Fields inherited from class org.apache.ambari.server.agent.stomp.AgentDataHolder

updateLock

Constructor Summary

Constructors

Constructor and Description
AlertDefinitionsHolder(AmbariEventPublisher eventPublisher)

Method Summary

Modifier and Type	Method and Description
protected AlertDefinitionsAgentUpdateEvent	getCurrentData(Long hostId)
AlertDefinitionsAgentUpdateEvent	getDeleteCluster(Long clusterId, Long hostId)
protected AlertDefinitionsAgentUpdateEvent	getEmptyData()
protected AlertDefinitionsAgentUpdateEvent	handleUpdate(AlertDefinitionsAgentUpdateEvent current, AlertDefinitionsAgentUpdateEvent update)
void	onHostsRemoved(HostsRemovedEvent event)
void	onHostToClusterAssign(HostsAddedEvent hostsAddedEvent)
void	provideAlertDefinitionAgentUpdateEvent(AlertDefinitionEventType eventType, Long clusterId, Map<Long,AlertDefinition> alertDefinitions, String hostName)
void	provideStaleAlertDefinitionUpdateEvent(AlertDefinitionEventType eventType, Long clusterId, Integer staleIntervalMultiplier, String hostName)

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

getData, getData, getUpdateIfChanged, initializeDataIfNeeded, onHostRemoved, resetData, setData, setIdentifiersToEventUpdate, updateData

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

getHash, getHash, isIdentifierValid, regenerateDataIdentifiers

Methods inherited from class java.lang.Object

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

Constructor Detail

AlertDefinitionsHolder

@Inject
public AlertDefinitionsHolder(AmbariEventPublisher eventPublisher)

Method Detail

getCurrentData

protected AlertDefinitionsAgentUpdateEvent getCurrentData(Long hostId)
                                                   throws org.apache.ambari.server.AmbariException

Specified by:

getCurrentData in class AgentHostDataHolder<AlertDefinitionsAgentUpdateEvent>

Throws:

org.apache.ambari.server.AmbariException

getDeleteCluster

public AlertDefinitionsAgentUpdateEvent getDeleteCluster(Long clusterId,
                                                         Long hostId)
                                                  throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getEmptyData

protected AlertDefinitionsAgentUpdateEvent getEmptyData()

Specified by:

getEmptyData in class AgentDataHolder<AlertDefinitionsAgentUpdateEvent>

handleUpdate

protected AlertDefinitionsAgentUpdateEvent handleUpdate(AlertDefinitionsAgentUpdateEvent current,
                                                        AlertDefinitionsAgentUpdateEvent update)
                                                 throws org.apache.ambari.server.AmbariException

Specified by:

handleUpdate in class AgentHostDataHolder<AlertDefinitionsAgentUpdateEvent>

Throws:

org.apache.ambari.server.AmbariException

onHostToClusterAssign

public void onHostToClusterAssign(HostsAddedEvent hostsAddedEvent)
                           throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

onHostsRemoved

public void onHostsRemoved(HostsRemovedEvent event)

provideAlertDefinitionAgentUpdateEvent

public void provideAlertDefinitionAgentUpdateEvent(AlertDefinitionEventType eventType,
                                                   Long clusterId,
                                                   Map<Long,AlertDefinition> alertDefinitions,
                                                   String hostName)
                                            throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

provideStaleAlertDefinitionUpdateEvent

public void provideStaleAlertDefinitionUpdateEvent(AlertDefinitionEventType eventType,
                                                   Long clusterId,
                                                   Integer staleIntervalMultiplier,
                                                   String hostName)
                                            throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException