org.opennms.netmgt.newts.support

Class RedisResourceMetadataCache

java.lang.Object

org.opennms.netmgt.newts.support.RedisResourceMetadataCache

All Implemented Interfaces:

SearchableResourceMetadataCache, org.opennms.newts.cassandra.search.ResourceMetadataCache

public class RedisResourceMetadataCache
extends Object
implements SearchableResourceMetadataCache

A caching strategy that stores the ResourceMetadata in a Redis database. Can be used when the cache needs to be shared amongst several JVMs, or when persistence is required. Note that this cache will operate slower than the GuavaSearchableResourceMetadataCache since it requires network I/O and serialization/deserialization of the associated structures. However, this cache will also operate with significantly less memory. FST is used for serialization instead Java's default implementation.

Author:

jwhite

Constructor Summary

Constructors

Constructor and Description
RedisResourceMetadataCache(String hostname, Integer port, Integer numWriterThreads, com.codahale.metrics.MetricRegistry registry, org.opennms.newts.cassandra.search.ResourceIdSplitter resourceIdSplitter)

Method Summary

Modifier and Type	Method and Description
void	delete(org.opennms.newts.api.Context context, org.opennms.newts.api.Resource resource)
com.google.common.base.Optional<org.opennms.newts.cassandra.search.ResourceMetadata>	get(org.opennms.newts.api.Context context, org.opennms.newts.api.Resource resource)
List<String>	getResourceIdsWithPrefix(org.opennms.newts.api.Context context, String resourceIdPrefix)
void	merge(org.opennms.newts.api.Context context, org.opennms.newts.api.Resource resource, org.opennms.newts.cassandra.search.ResourceMetadata metadata)

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisResourceMetadataCache

@Inject
public RedisResourceMetadataCache(@Named(value="redis.hostname")
                                          String hostname,
                                          @Named(value="redis.port")
                                          Integer port,
                                          @Named(value="newts.writer_threads")
                                          Integer numWriterThreads,
                                          @Named(value="newtsMetricRegistry")
                                          com.codahale.metrics.MetricRegistry registry,
                                          org.opennms.newts.cassandra.search.ResourceIdSplitter resourceIdSplitter)

Method Detail

merge

public void merge(org.opennms.newts.api.Context context,
                  org.opennms.newts.api.Resource resource,
                  org.opennms.newts.cassandra.search.ResourceMetadata metadata)

Specified by:

merge in interface org.opennms.newts.cassandra.search.ResourceMetadataCache

get

public com.google.common.base.Optional<org.opennms.newts.cassandra.search.ResourceMetadata> get(org.opennms.newts.api.Context context,
                                                                                                org.opennms.newts.api.Resource resource)

Specified by:

get in interface org.opennms.newts.cassandra.search.ResourceMetadataCache

delete

public void delete(org.opennms.newts.api.Context context,
                   org.opennms.newts.api.Resource resource)

Specified by:

delete in interface org.opennms.newts.cassandra.search.ResourceMetadataCache

getResourceIdsWithPrefix

public List<String> getResourceIdsWithPrefix(org.opennms.newts.api.Context context,
                                             String resourceIdPrefix)

Specified by:

getResourceIdsWithPrefix in interface SearchableResourceMetadataCache