public class MongoStorage extends Storage
Modifier and Type | Field and Description |
---|---|
static String |
KEY_AGENT_ID |
static String |
SET_MODIFIER |
Constructor and Description |
---|
MongoStorage(StartupConfiguration conf) |
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) |
registerCategory
public static final String KEY_AGENT_ID
public static final String SET_MODIFIER
public MongoStorage(StartupConfiguration conf)
public Connection getConnection()
getConnection
in class Storage
public void setAgentId(UUID agentId)
setAgentId
in class Storage
public void updateChunk(Chunk chunk)
updateChunk
in class Storage
public void purge()
Storage
public ConnectionKey createConnectionKey(Category category)
createConnectionKey
in class Storage
public Cursor findAllFromCategory(Category category)
findAllFromCategory
in class Storage
public void addAgentInformation(AgentInformation agentInfo)
addAgentInformation
in class Storage
public void updateAgentInformation(AgentInformation agentInfo)
updateAgentInformation
in class Storage
public void removeAgentInformation()
removeAgentInformation
in class Storage
public String getBackendConfig(String backendName, String configurationKey)
getBackendConfig
in class Storage
null
if the value is invalid or missingCopyright © 2012. All Rights Reserved.