com.redhat.thermostat.agent.storage

Class MongoStorage

java.lang.Object

com.redhat.thermostat.agent.storage.Storage

com.redhat.thermostat.agent.storage.MongoStorage

public class MongoStorage
extends Storage

Implementation of the Storage interface that uses MongoDB to store the instrumentation data. In this implementation, each CATEGORY is given a distinct collection.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	KEY_AGENT_ID
static java.lang.String	SET_MODIFIER

Constructor Summary

Constructors

Constructor and Description
MongoStorage()

Method Summary

Methods

Modifier and Type	Method and Description
void	addAgentInformation(StartupConfiguration config, BackendRegistry registry)
void	connect(java.lang.String uri)
java.lang.String	getBackendConfig(java.lang.String backendName, java.lang.String configurationKey)
void	purge()
protected void	putChunkImpl(Chunk chunk)
void	removeAgentInformation()
void	setAgentId(java.util.UUID agentId)
protected void	updateChunkImpl(Chunk chunk)

Methods inherited from class com.redhat.thermostat.agent.storage.Storage

putChunk, registerCategory, updateChunk

Methods inherited from class java.lang.Object

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

Field Detail

KEY_AGENT_ID

public static final java.lang.String KEY_AGENT_ID

See Also:

Constant Field Values

SET_MODIFIER

public static final java.lang.String SET_MODIFIER

See Also:

Constant Field Values

Constructor Detail

MongoStorage

public MongoStorage()

Method Detail

connect

public void connect(java.lang.String uri)
             throws java.net.UnknownHostException

Specified by:

connect in class Storage

Throws:

java.net.UnknownHostException

setAgentId

public void setAgentId(java.util.UUID agentId)

Specified by:

setAgentId in class Storage

addAgentInformation

public void addAgentInformation(StartupConfiguration config,
                       BackendRegistry registry)

Specified by:

addAgentInformation in class Storage

removeAgentInformation

public void removeAgentInformation()

Specified by:

removeAgentInformation in class Storage

getBackendConfig

public java.lang.String getBackendConfig(java.lang.String backendName,
                                java.lang.String configurationKey)

Specified by:

getBackendConfig in class Storage

Returns:

null if the value is invalid or missing

putChunkImpl

protected void putChunkImpl(Chunk chunk)

Specified by:

putChunkImpl in class Storage

updateChunkImpl

protected void updateChunkImpl(Chunk chunk)

Specified by:

updateChunkImpl in class Storage

purge

public void purge()

Specified by:

purge in class Storage