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 final class RedisRichGaugeRepository
extends java.lang.Object
implements RichGaugeRepository

Author:

Luke Taylor

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
RedisRichGaugeRepository(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

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) 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	setAlpha(java.lang.String name, double value) Sets the "smoothing constant", "alpha" for use in calculating an exponential moving average for the gauge.
void	setValue(java.lang.String name, double value) Sets the current 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

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

RedisRichGaugeRepository

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

Method Detail

setValue

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

Description copied from interface: RichGaugeRepository

Sets the current value of the gauge.

Specified by:

setValue in interface RichGaugeRepository

Parameters:

name - the gauge name

value - the value of the gauge

setAlpha

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

Description copied from interface: RichGaugeRepository

Sets the "smoothing constant", "alpha" for use in calculating an exponential moving average for the gauge. If this is not set, a simple arithmetic mean will be stored.

The parameter can be set at any time after the gauge has been created. The mean calculated up to that point will be used to initialize the moving average from that point on.

Specified by:

setAlpha in interface RichGaugeRepository

Parameters:

name - the gauge name

value - the value of the gauge

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

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>