org.springframework.xd.analytics.metrics.redis

Class RedisFieldValueCounterRepository

java.lang.Object

org.springframework.xd.analytics.metrics.redis.RedisFieldValueCounterRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>, org.springframework.data.repository.Repository<FieldValueCounter,java.lang.String>, FieldValueCounterRepository, MetricRepository<FieldValueCounter>

public class RedisFieldValueCounterRepository
extends java.lang.Object
implements FieldValueCounterRepository

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	metricPrefix
protected org.springframework.data.redis.core.StringRedisTemplate	redisTemplate

Constructor Summary

Constructors

Constructor and Description
RedisFieldValueCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
RedisFieldValueCounterRepository(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 counterName, java.lang.String fieldName)
void	decrement(java.lang.String counterName, java.lang.String fieldName, double score)
void	delete(FieldValueCounter fieldValueCounter)
void	delete(java.lang.Iterable<? extends FieldValueCounter> fvcs)
void	delete(java.lang.String name)
void	deleteAll()
boolean	exists(java.lang.String s)
java.util.List<FieldValueCounter>	findAll()
java.lang.Iterable<FieldValueCounter>	findAll(java.lang.Iterable<java.lang.String> keys)
FieldValueCounter	findOne(java.lang.String name)
protected java.lang.String	getMetricKey(java.lang.String metricName) Provides the key for a named metric.
protected java.util.Map<java.lang.String,java.lang.Double>	getZSetData(java.lang.String counterKey)
void	increment(java.lang.String counterName, java.lang.String fieldName)
void	increment(java.lang.String counterName, java.lang.String fieldName, double score)
void	reset(java.lang.String counterName, java.lang.String fieldName)
<S extends FieldValueCounter> java.lang.Iterable<S>	save(java.lang.Iterable<S> metrics)
<S extends FieldValueCounter> S	save(S fieldValueCounter)

Methods inherited from class java.lang.Object

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

Field Detail

metricPrefix

protected final java.lang.String metricPrefix

redisTemplate

protected final org.springframework.data.redis.core.StringRedisTemplate redisTemplate

Constructor Detail

RedisFieldValueCounterRepository

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

RedisFieldValueCounterRepository

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

Method Detail

save

public <S extends FieldValueCounter> S save(S fieldValueCounter)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

save

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

Specified by:

save in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

delete

public void delete(java.lang.String name)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

delete

public void delete(FieldValueCounter fieldValueCounter)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

delete

public void delete(java.lang.Iterable<? extends FieldValueCounter> fvcs)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

findOne

public FieldValueCounter findOne(java.lang.String name)

Specified by:

findOne in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

exists

public boolean exists(java.lang.String s)

Specified by:

exists in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

findAll

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

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

findAll

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

Specified by:

findAll in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

count

public long count()

Specified by:

count in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<FieldValueCounter,java.lang.String>

increment

public void increment(java.lang.String counterName,
             java.lang.String fieldName)

increment

public void increment(java.lang.String counterName,
             java.lang.String fieldName,
             double score)

decrement

public void decrement(java.lang.String counterName,
             java.lang.String fieldName)

decrement

public void decrement(java.lang.String counterName,
             java.lang.String fieldName,
             double score)

reset

public void reset(java.lang.String counterName,
         java.lang.String fieldName)

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

getZSetData

protected java.util.Map<java.lang.String,java.lang.Double> getZSetData(java.lang.String counterKey)