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	SET_MODIFIER

Constructor Summary

Constructors

Constructor and Description
MongoStorage(StartupConfiguration conf)

Method Summary

Methods

Modifier and Type	Method and Description
ConnectionKey	createConnectionKey(Category category)
Query	createQuery()
Remove	createRemove()
Update	createUpdate()
<T extends Pojo> Cursor<T>	findAllPojos(Query query, Class<T> resultClass)
<T extends Pojo> T	findPojo(Query query, Class<T> resultClass)
String	getAgentId()
Connection	getConnection()
long	getCount(Category category)
InputStream	loadFile(String filename)
void	purge() Drop all data related to the currently running agent.
void	putPojo(Category category, boolean replace, Pojo pojo)
void	removePojo(Remove remove)
void	saveFile(String filename, InputStream data)
void	setAgentId(UUID agentId)
void	updatePojo(Update update)

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

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

getAgentId

public String getAgentId()

Specified by:

getAgentId in class Storage

updatePojo

public void updatePojo(Update update)

Specified by:

updatePojo in class Storage

removePojo

public void removePojo(Remove remove)

Specified by:

removePojo 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

createQuery

public Query createQuery()

Specified by:

createQuery in class Storage

createUpdate

public Update createUpdate()

Specified by:

createUpdate in class Storage

createRemove

public Remove createRemove()

Specified by:

createRemove in class Storage

findAllPojos

public <T extends Pojo> Cursor<T> findAllPojos(Query query,
                                      Class<T> resultClass)

Specified by:

findAllPojos in class Storage

findPojo

public <T extends Pojo> T findPojo(Query query,
                          Class<T> resultClass)

Specified by:

findPojo in class Storage

getCount

public long getCount(Category category)

Specified by:

getCount in class Storage

saveFile

public void saveFile(String filename,
            InputStream data)

Specified by:

saveFile in class Storage

loadFile

public InputStream loadFile(String filename)

Specified by:

loadFile in class Storage

putPojo

public void putPojo(Category category,
           boolean replace,
           Pojo pojo)

Specified by:

putPojo in class Storage