org.springframework.xd.analytics.metrics.redis

Class RedisCounterRepository

java.lang.Object

org.springframework.xd.store.AbstractRedisRepository<Counter,java.lang.String>

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

All Implemented Interfaces:

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

Direct Known Subclasses:

RedisAggregateCounterRepository

@Qualifier(value="simple")
public class RedisCounterRepository
extends AbstractRedisRepository<Counter,java.lang.String>
implements CounterRepository

Author:

Eric Bottard

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.data.redis.core.ValueOperations<java.lang.String,java.lang.Long>	longOperations

Fields inherited from class org.springframework.xd.store.AbstractRedisRepository

redisOperations, repoPrefix, zSetOperations

Constructor Summary

Constructors

Constructor and Description
RedisCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory, org.springframework.retry.RetryOperations retryOperations)
RedisCounterRepository(java.lang.String repoPrefix, org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory, org.springframework.retry.RetryOperations retryOperations)

Method Summary

Methods

Modifier and Type	Method and Description
long	decrement(java.lang.String name) Decrement the given counter, creating it if it did not exist.
protected Counter	deserialize(java.lang.String redisKey, java.lang.String v) Deserialize from the String representation to the domain object.
protected java.lang.String	deserializeId(java.lang.String string) Deserialize an entity id from its String representation.
long	increment(java.lang.String name) Increment the given counter by one, creating it if it did not exist.
long	increment(java.lang.String name, long amount) Increment the given counter by the specified amount, creating it if it did not exist.
protected java.lang.String	keyFor(Counter entity) Return the entity id for the given domain object.
void	reset(java.lang.String name) Reset the given counter to zero.
protected java.lang.String	serialize(Counter entity) Provide a String representation of the domain entity.
protected java.lang.String	serializeId(java.lang.String id) Return a String representation of the domain ID.

Methods inherited from class org.springframework.xd.store.AbstractRedisRepository

count, delete, delete, delete, deleteAll, exists, findAll, findAll, findAll, findAll, findAllInRange, findOne, getPrefix, idFromRedisKey, redisKeyFromId, save, save, setPrefix, trackMembership

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.PagingAndSortingRepository

findAll, findAll

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, delete, delete, deleteAll, exists, findAll, findAll, findOne, save, save

Methods inherited from interface org.springframework.xd.store.RangeCapableRepository

findAllInRange

Field Detail

longOperations

protected org.springframework.data.redis.core.ValueOperations<java.lang.String,java.lang.Long> longOperations

Constructor Detail

RedisCounterRepository

public RedisCounterRepository(org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory,
                      org.springframework.retry.RetryOperations retryOperations)

RedisCounterRepository

public RedisCounterRepository(java.lang.String repoPrefix,
                      org.springframework.data.redis.connection.RedisConnectionFactory redisConnectionFactory,
                      org.springframework.retry.RetryOperations retryOperations)

Method Detail

deserialize

protected Counter deserialize(java.lang.String redisKey,
                  java.lang.String v)

Description copied from class: AbstractRedisRepository

Deserialize from the String representation to the domain object.

Specified by:

deserialize in class AbstractRedisRepository<Counter,java.lang.String>

Parameters:

redisKey - the entity id

v - the serialized representation of the domain object

serialize

protected java.lang.String serialize(Counter entity)

Description copied from class: AbstractRedisRepository

Provide a String representation of the domain entity.

Specified by:

serialize in class AbstractRedisRepository<Counter,java.lang.String>

keyFor

protected java.lang.String keyFor(Counter entity)

Description copied from class: AbstractRedisRepository

Return the entity id for the given domain object.

Specified by:

keyFor in class AbstractRedisRepository<Counter,java.lang.String>

serializeId

protected java.lang.String serializeId(java.lang.String id)

Description copied from class: AbstractRedisRepository

Return a String representation of the domain ID. Note that order should be preserved between ID domain and String representation.

Specified by:

serializeId in class AbstractRedisRepository<Counter,java.lang.String>

deserializeId

protected java.lang.String deserializeId(java.lang.String string)

Description copied from class: AbstractRedisRepository

Deserialize an entity id from its String representation.

Specified by:

deserializeId in class AbstractRedisRepository<Counter,java.lang.String>

increment

public long increment(java.lang.String name)

Description copied from interface: CounterRepository

Increment the given counter by one, creating it if it did not exist. Implementations which can do this atomically in one operation are encouraged to do so.

Specified by:

increment in interface CounterRepository

increment

public long increment(java.lang.String name,
             long amount)

Description copied from interface: CounterRepository

Increment the given counter by the specified amount, creating it if it did not exist. Implementations which can do this atomically in one operation are encouraged to do so.

Specified by:

increment in interface CounterRepository

decrement

public long decrement(java.lang.String name)

Description copied from interface: CounterRepository

Decrement the given counter, creating it if it did not exist. Implementations which can do this atomically in one operation are encouraged to do so.

Specified by:

decrement in interface CounterRepository

reset

public void reset(java.lang.String name)

Description copied from interface: CounterRepository

Reset the given counter to zero.

Specified by:

reset in interface CounterRepository