com.redhat.thermostat.common.storage

Class MongoStorage

java.lang.Object

com.redhat.thermostat.common.storage.Storage

com.redhat.thermostat.common.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 String	KEY_AGENT_ID
static String	SET_MODIFIER

Constructor Summary

Constructors

Constructor and Description
MongoStorage(StartupConfiguration conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	addAgentInformation(AgentInformation agentInfo)
ConnectionKey	createConnectionKey(Category category)
Chunk	find(Chunk query)
Cursor	findAll(Chunk query)
Cursor	findAllFromCategory(Category category)
String	getBackendConfig(String backendName, String configurationKey)
Connection	getConnection()
long	getCount(Category category)
void	purge() Drop all data related to the currently running agent.
void	putChunk(Chunk chunk)
void	removeAgentInformation()
void	setAgentId(UUID agentId)
void	updateAgentInformation(AgentInformation agentInfo)
void	updateChunk(Chunk chunk)

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

registerCategory

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 String KEY_AGENT_ID

See Also:

Constant Field Values

SET_MODIFIER

public static final String SET_MODIFIER

See Also:

Constant Field Values

Constructor Detail

MongoStorage

public MongoStorage(StartupConfiguration conf)

Method Detail

getConnection

public Connection getConnection()

Specified by:

getConnection in class Storage

setAgentId

public void setAgentId(UUID agentId)

Specified by:

setAgentId in class Storage

putChunk

public void putChunk(Chunk chunk)

Specified by:

putChunk in class Storage

updateChunk

public void updateChunk(Chunk chunk)

Specified by:

updateChunk in class Storage

purge

public void purge()

Description copied from class: Storage

Drop all data related to the currently running agent.

Specified by:

purge in class Storage

createConnectionKey

public ConnectionKey createConnectionKey(Category category)

Specified by:

createConnectionKey in class Storage

findAll

public Cursor findAll(Chunk query)

Specified by:

findAll in class Storage

find

public Chunk find(Chunk query)

Specified by:

find in class Storage

findAllFromCategory

public Cursor findAllFromCategory(Category category)

Specified by:

findAllFromCategory in class Storage

getCount

public long getCount(Category category)

Specified by:

getCount in class Storage

addAgentInformation

public void addAgentInformation(AgentInformation agentInfo)

Specified by:

addAgentInformation in class Storage

updateAgentInformation

public void updateAgentInformation(AgentInformation agentInfo)

Specified by:

updateAgentInformation in class Storage

removeAgentInformation

public void removeAgentInformation()

Specified by:

removeAgentInformation in class Storage

getBackendConfig

public String getBackendConfig(String backendName,
                      String configurationKey)

Specified by:

getBackendConfig in class Storage

Returns:

null if the value is invalid or missing