org.springframework.xd.analytics.metrics.redis

Class RedisCounterRepository

java.lang.Object

org.springframework.xd.analytics.metrics.redis.RedisCounterRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<Counter,java.lang.String>, org.springframework.data.repository.Repository<Counter,java.lang.String>, CounterRepository, MetricRepository<Counter>

public final class RedisCounterRepository
extends java.lang.Object
implements CounterRepository

Redis backed implementation that uses Redis keys to store and update the value. The naming strategy for keys in Redis is "counters." This means a counter named simpleCounter appears under the name "counters.simpleCounter" in Redis. There is a default expiry of 60 minutes for the counters stored in redis. This can be changed using a setter method

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
RedisCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
RedisCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, java.lang.String metricPrefix)

Method Summary

Methods

Modifier and Type	Method and Description
long	count()
void	decrement(java.lang.String name)
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	increment(java.lang.String name)
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)

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

RedisCounterRepository

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

RedisCounterRepository

public RedisCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
                      java.lang.String metricPrefix)

Method Detail

increment

public void increment(java.lang.String name)

decrement

public void decrement(java.lang.String name)

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>