org.springframework.xd.analytics.metrics.memory

Class InMemoryCounterRepository

java.lang.Object

org.springframework.xd.analytics.metrics.memory.InMemoryCounterRepository

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 class InMemoryCounterRepository
extends java.lang.Object
implements CounterRepository

Memory backed implementation of Counter repository that uses a ConcurrentMap.

Author:

Mark Pollack

Constructor Summary

Constructors

Constructor and Description
InMemoryCounterRepository()

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.util.List<M>	findAll(java.lang.Iterable<java.lang.String> keys)
M	findOne(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

Constructor Detail

InMemoryCounterRepository

public InMemoryCounterRepository()

Method Detail

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.util.List<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>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface org.springframework.data.repository.CrudRepository<M extends Metric,java.lang.String>