org.springframework.xd.analytics.metrics.redis

Class RedisGaugeRepository

java.lang.Object

org.springframework.xd.analytics.metrics.redis.RedisGaugeRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<Gauge,java.lang.String>, org.springframework.data.repository.Repository<Gauge,java.lang.String>, GaugeRepository, MetricRepository<Gauge>

public class RedisGaugeRepository
extends java.lang.Object
implements GaugeRepository

Redis backed implementation that uses Redis keys to store and update the value. The naming strategy for keys in Redis is "gauges." This means a Gauge named simpleGauge appears under the name "gauges.simpleGauge" in Redis.

Author:

Mark Pollack

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	metricPrefix
protected org.springframework.data.redis.core.RedisOperations<java.lang.String,V>	redisOperations
protected org.springframework.data.redis.core.ValueOperations<java.lang.String,V>	valueOperations

Constructor Summary

Constructors

Constructor and Description
RedisGaugeRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
RedisGaugeRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, java.lang.String gaugePrefix)

Method Summary

Methods

Modifier and Type	Method and Description
long	count()
void	delete(java.lang.Iterable<? extends M> metrics)
void	delete(M metric)
void	delete(java.lang.String name)
void	deleteAll()
boolean	exists(java.lang.String s)
java.util.List<M>	findAll()
java.lang.Iterable<M>	findAll(java.lang.Iterable<java.lang.String> keys)
M	findOne(java.lang.String name)
protected java.lang.String	getMetricKey(java.lang.String metricName) Provides the key for a named metric.
void	reset(java.lang.String name)
<S extends M> java.lang.Iterable<S>	save(java.lang.Iterable<S> metrics)
<S extends M> S	save(S metric)
void	setValue(java.lang.String name, long value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, delete, delete, deleteAll, exists, findAll, findAll, findOne, save, save

Field Detail

metricPrefix

protected final java.lang.String metricPrefix

valueOperations

protected final org.springframework.data.redis.core.ValueOperations<java.lang.String,V> valueOperations

redisOperations

protected final org.springframework.data.redis.core.RedisOperations<java.lang.String,V> redisOperations

Constructor Detail

RedisGaugeRepository

public RedisGaugeRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

RedisGaugeRepository

public RedisGaugeRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
                    java.lang.String gaugePrefix)

Method Detail

setValue

public void setValue(java.lang.String name,
            long value)

reset

public void reset(java.lang.String name)

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

getMetricKey

protected java.lang.String getMetricKey(java.lang.String metricName)

Provides the key for a named metric. By default this appends the name to the metricPrefix value.

Parameters:

metricName - the name of the metric

Returns:

the redis key under which the metric is stored

save

public <S extends M> S save(S metric)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

save

public <S extends M> java.lang.Iterable<S> save(java.lang.Iterable<S> metrics)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

delete

public void delete(java.lang.String name)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

delete

public void delete(M metric)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

delete

public void delete(java.lang.Iterable<? extends M> metrics)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

findOne

public M findOne(java.lang.String name)

Specified by:

findOne in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

exists

public boolean exists(java.lang.String s)

Specified by:

exists in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

findAll

public java.util.List<M> findAll()

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

findAll

public java.lang.Iterable<M> findAll(java.lang.Iterable<java.lang.String> keys)

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>

count

public long count()

Specified by:

count in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>