Package org.opennms.netmgt.timeseries.meta

Class TimeSeriesMetaDataDao

java.lang.Object

org.opennms.netmgt.timeseries.meta.TimeSeriesMetaDataDao

@Service
public class TimeSeriesMetaDataDao
extends java.lang.Object

TimeSeriesMetaDataDao stores string values associated with resourceids in the database. It leverages a Guava cache. Design choice: for speed and high throughput we don't keep the cache and the database 100% in sync at the time of writing. Latest 'cache_duration' after writing they will be the same.

Constructor Summary

Constructors

Constructor	Description
TimeSeriesMetaDataDao(javax.sql.DataSource dataSource, CacheConfig cacheConfig, com.codahale.metrics.MetricRegistry registry)

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,java.lang.String>	getForResourcePath(ResourcePath path)
void	store(java.util.Collection<MetaData> metaDataCollection)
void	storeUncached(java.util.Collection<MetaData> metaDataCollection)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeSeriesMetaDataDao

@Autowired
public TimeSeriesMetaDataDao(javax.sql.DataSource dataSource,
                             @Named("timeseriesMetaDataCache")
                             CacheConfig cacheConfig,
                             @Named("timeseriesMetricRegistry")
                             com.codahale.metrics.MetricRegistry registry)

Method Detail

store

public void store(java.util.Collection<MetaData> metaDataCollection)
           throws java.sql.SQLException,
                  java.util.concurrent.ExecutionException

Throws:

java.sql.SQLException

java.util.concurrent.ExecutionException

storeUncached

public void storeUncached(java.util.Collection<MetaData> metaDataCollection)
                   throws java.sql.SQLException

Throws:

java.sql.SQLException

getForResourcePath

public java.util.Map<java.lang.String,java.lang.String> getForResourcePath(ResourcePath path)
                                                                          throws org.opennms.integration.api.v1.timeseries.StorageException

Throws:

org.opennms.integration.api.v1.timeseries.StorageException