Constructor and Description |
---|
MongoStorage(StartupConfiguration conf) |
Modifier and Type | Method and Description |
---|---|
Add |
createAdd(Category<?> into) |
<T extends Pojo> |
createQuery(Category<T> category) |
Remove |
createRemove() |
Replace |
createReplace(Category<?> into) |
Update |
createUpdate(Category<?> category) |
String |
getAgentId() |
Connection |
getConnection()
Returns the Connection object that may be used to manage connections
to this Storage.
|
long |
getCount(Category<?> category) |
InputStream |
loadFile(String filename) |
void |
purge(String agentId)
Drop all data related to the currently running agent.
|
void |
registerCategory(Category<?> category) |
void |
removePojo(Remove remove) |
void |
saveFile(String filename,
InputStream data) |
void |
setAgentId(UUID agentId) |
void |
shutdown() |
public MongoStorage(StartupConfiguration conf)
public Connection getConnection()
Storage
getConnection
in interface Storage
public void setAgentId(UUID agentId)
setAgentId
in interface Storage
public String getAgentId()
getAgentId
in interface Storage
public Replace createReplace(Category<?> into)
createReplace
in interface Storage
public void removePojo(Remove remove)
removePojo
in interface Storage
public void purge(String agentId)
Storage
public void registerCategory(Category<?> category)
registerCategory
in interface Storage
public <T extends Pojo> Query<T> createQuery(Category<T> category)
createQuery
in interface Storage
public Update createUpdate(Category<?> category)
createUpdate
in interface Storage
public Remove createRemove()
createRemove
in interface Storage
public void saveFile(String filename, InputStream data)
public InputStream loadFile(String filename)
Copyright © 2013. All Rights Reserved.