org.springframework.xd.analytics.metrics.redis

Class RedisRichGaugeRepository

java.lang.Object

org.springframework.xd.analytics.metrics.redis.RedisRichGaugeRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<RichGauge,java.lang.String>, org.springframework.data.repository.Repository<RichGauge,java.lang.String>, MetricRepository<RichGauge>, RichGaugeRepository

public class RedisRichGaugeRepository
extends java.lang.Object
implements RichGaugeRepository

Repository for rich-gauges backed by Redis.

Author:

Luke Taylor, Eric Bottard

Constructor Summary

Constructors

Constructor and Description
RedisRichGaugeRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, org.springframework.retry.RetryOperations retryOperations)

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	recordValue(java.lang.String name, double value, double alpha) Set the current value of the gauge, smoothing accumulated values with the provided alpha value.
void	reset(java.lang.String name) Reset the gauge to zero and reset any accumulated average, max and min values
<S extends M> java.lang.Iterable<S>	save(java.lang.Iterable<S> metrics)
<S extends M> S	save(S metric)
void	setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

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

RedisRichGaugeRepository

public RedisRichGaugeRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
                        org.springframework.retry.RetryOperations retryOperations)

Method Detail

recordValue

public void recordValue(java.lang.String name,
               double value,
               double alpha)

Description copied from interface: RichGaugeRepository

Set the current value of the gauge, smoothing accumulated values with the provided alpha value.

Specified by:

recordValue in interface RichGaugeRepository

Parameters:

name - the gauge name

value - the value of the gauge

alpha - the smoothing factor to use

setRetryTemplate

public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)

reset

public void reset(java.lang.String name)

Description copied from interface: RichGaugeRepository

Reset the gauge to zero and reset any accumulated average, max and min values

Specified by:

reset in interface RichGaugeRepository

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>