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

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.
org.springframework.data.redis.core.RedisOperations<java.lang.String,V>	getRedisOperations()
org.springframework.data.redis.core.ValueOperations<java.lang.String,V>	getValueOperations()
void	reset(java.lang.String name) Reset the gauge to zero
<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) Set the value of the gauge

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

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)

Description copied from interface: GaugeRepository

Set the value of the gauge

Specified by:

setValue in interface GaugeRepository

Parameters:

name - the gauge name

value - the value of the gauge

reset

public void reset(java.lang.String name)

Description copied from interface: GaugeRepository

Reset the gauge to zero

Specified by:

reset in interface GaugeRepository

Parameters:

name - the gauge name

getValueOperations

public org.springframework.data.redis.core.ValueOperations<java.lang.String,V> getValueOperations()

getRedisOperations

public org.springframework.data.redis.core.RedisOperations<java.lang.String,V> getRedisOperations()

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>