org.apache.ambari.server.agent.stomp

Class AgentConfigsHolder

java.lang.Object

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

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

org.apache.ambari.server.agent.stomp.AgentConfigsHolder

public class AgentConfigsHolder
extends AgentHostDataHolder<AgentConfigsUpdateEvent>

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

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

updateLock

Constructor Summary

Constructors

Constructor and Description
AgentConfigsHolder(AmbariEventPublisher ambariEventPublisher, Encryptor<AgentConfigsUpdateEvent> encryptor)

Method Summary

Modifier and Type	Method and Description
AgentConfigsUpdateEvent	getCurrentData(Long hostId)
AgentConfigsUpdateEvent	getCurrentDataExcludeCluster(Long hostId, Long clusterId)
protected AgentConfigsUpdateEvent	getEmptyData()
AgentConfigsUpdateEvent	getUpdateIfChanged(String agentHash, Long hostId)
protected AgentConfigsUpdateEvent	handleUpdate(AgentConfigsUpdateEvent current, AgentConfigsUpdateEvent update)
protected boolean	isIdentifierValid(AgentConfigsUpdateEvent data)
protected void	regenerateDataIdentifiers(AgentConfigsUpdateEvent data)
protected void	setIdentifiersToEventUpdate(AgentConfigsUpdateEvent update, AgentConfigsUpdateEvent hostData)
void	updateData(Long clusterId, List<Long> hostIds)

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

getData, getData, initializeDataIfNeeded, onHostRemoved, resetData, setData, updateData

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

getHash, getHash

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

AgentConfigsHolder

@Inject
public AgentConfigsHolder(AmbariEventPublisher ambariEventPublisher,
                                  Encryptor<AgentConfigsUpdateEvent> encryptor)

Method Detail

getCurrentData

public AgentConfigsUpdateEvent getCurrentData(Long hostId)
                                       throws org.apache.ambari.server.AmbariException

Specified by:

getCurrentData in class AgentHostDataHolder<AgentConfigsUpdateEvent>

Throws:

org.apache.ambari.server.AmbariException

getCurrentDataExcludeCluster

public AgentConfigsUpdateEvent getCurrentDataExcludeCluster(Long hostId,
                                                            Long clusterId)
                                                     throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

handleUpdate

protected AgentConfigsUpdateEvent handleUpdate(AgentConfigsUpdateEvent current,
                                               AgentConfigsUpdateEvent update)

Specified by:

handleUpdate in class AgentHostDataHolder<AgentConfigsUpdateEvent>

updateData

public void updateData(Long clusterId,
                       List<Long> hostIds)
                throws org.apache.ambari.server.AmbariException

Throws:

org.apache.ambari.server.AmbariException

getUpdateIfChanged

public AgentConfigsUpdateEvent getUpdateIfChanged(String agentHash,
                                                  Long hostId)
                                           throws org.apache.ambari.server.AmbariException

Overrides:

getUpdateIfChanged in class AgentHostDataHolder<AgentConfigsUpdateEvent>

Throws:

org.apache.ambari.server.AmbariException

regenerateDataIdentifiers

protected void regenerateDataIdentifiers(AgentConfigsUpdateEvent data)

Overrides:

regenerateDataIdentifiers in class AgentDataHolder<AgentConfigsUpdateEvent>

isIdentifierValid

protected boolean isIdentifierValid(AgentConfigsUpdateEvent data)

Overrides:

isIdentifierValid in class AgentDataHolder<AgentConfigsUpdateEvent>

setIdentifiersToEventUpdate

protected void setIdentifiersToEventUpdate(AgentConfigsUpdateEvent update,
                                           AgentConfigsUpdateEvent hostData)

Overrides:

setIdentifiersToEventUpdate in class AgentHostDataHolder<AgentConfigsUpdateEvent>

getEmptyData

protected AgentConfigsUpdateEvent getEmptyData()

Specified by:

getEmptyData in class AgentDataHolder<AgentConfigsUpdateEvent>