com.redhat.thermostat.storage.core

Class QueuedStorage

java.lang.Object

com.redhat.thermostat.storage.core.QueuedStorage

All Implemented Interfaces:

Storage

Direct Known Subclasses:

SecureQueuedStorage

public class QueuedStorage
extends Object
implements Storage

Field Summary

Fields

Modifier and Type	Field and Description
protected Storage	delegate
protected ExecutorService	executor
protected ExecutorService	fileExecutor
protected boolean	isBackingStorageInProxy
protected boolean	isTimedStatements
protected com.redhat.thermostat.shared.perflog.PerformanceLogFormatter	perfLogFormatter

Constructor Summary

Constructors

Constructor and Description
QueuedStorage(Storage delegate)
QueuedStorage(Storage delegate, com.redhat.thermostat.shared.perflog.PerformanceLogFormatter perfLogFormatter)

Method Summary

Modifier and Type	Method and Description
Connection	getConnection() Returns the Connection object that may be used to manage connections to this Storage.
InputStream	loadFile(String filename) Load the file with the given name and return the data as an InputStream.
<T extends Pojo> PreparedStatement<T>	prepareStatement(StatementDescriptor<T> desc) Prepares the given statement for execution.
void	purge(String agentId) Drop all data related to the specified agent.
void	registerCategory(Category<?> category) Register the category into the Storage.
void	saveFile(String filename, InputStream data) Save the contents of the input stream as the given name.
void	shutdown() Shutdown the storage

Methods inherited from class java.lang.Object

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

Field Detail

isBackingStorageInProxy

protected final boolean isBackingStorageInProxy

isTimedStatements

protected final boolean isTimedStatements

perfLogFormatter

protected final com.redhat.thermostat.shared.perflog.PerformanceLogFormatter perfLogFormatter

delegate

protected final Storage delegate

executor

protected final ExecutorService executor

fileExecutor

protected final ExecutorService fileExecutor

Constructor Detail

QueuedStorage

public QueuedStorage(Storage delegate)

QueuedStorage

public QueuedStorage(Storage delegate,
                     com.redhat.thermostat.shared.perflog.PerformanceLogFormatter perfLogFormatter)

Method Detail

purge

public void purge(String agentId)

Description copied from interface: Storage

Drop all data related to the specified agent.

Specified by:

purge in interface Storage

Parameters:

agentId - The id of the agent

saveFile

public void saveFile(String filename,
                     InputStream data)

Description copied from interface: Storage

Save the contents of the input stream as the given name.

Specified by:

saveFile in interface Storage

Parameters:

filename - the name to save this data stream as. This must be unique across all machines and processes using the storage or it will overwrite data.

data - the data to save

loadFile

public InputStream loadFile(String filename)

Description copied from interface: Storage

Load the file with the given name and return the data as an InputStream.

Specified by:

loadFile in interface Storage

Returns:

the data as an InputStream or null if not found.

registerCategory

public void registerCategory(Category<?> category)

Description copied from interface: Storage

Register the category into the Storage. A Category must be registered into storage (normally handled by the Category's constructor) before it can be used.

Specified by:

registerCategory in interface Storage

prepareStatement

public <T extends Pojo> PreparedStatement<T> prepareStatement(StatementDescriptor<T> desc)
                                                       throws DescriptorParsingException

Description copied from interface: Storage

Prepares the given statement for execution.

Specified by:

prepareStatement in interface Storage

Parameters:

desc - The statement descriptor to prepare.

Returns:

A PreparedStatement if the given statement descriptor was known and did not fail to parse.

Throws:

DescriptorParsingException - If the descriptor string failed to parse.

IllegalDescriptorException - If storage refused to prepare a statement descriptor for security reasons.

getConnection

public Connection getConnection()

Description copied from interface: Storage

Returns the Connection object that may be used to manage connections to this Storage. Subsequent calls to this method should return the same Connection.

Specified by:

getConnection in interface Storage

Returns:

the Connection for this Storage

shutdown

public void shutdown()

Description copied from interface: Storage

Shutdown the storage

Specified by:

shutdown in interface Storage