org.springframework.xd.analytics.metrics.memory

Class InMemoryMetricRepository<M extends Metric>

java.lang.Object

org.springframework.xd.analytics.metrics.memory.InMemoryMetricRepository<M>

All Implemented Interfaces:

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

Direct Known Subclasses:

InMemoryFieldValueCounterRepository, InMemoryGaugeRepository, InMemoryRichGaugeRepository

public abstract class InMemoryMetricRepository<M extends Metric>
extends java.lang.Object
implements MetricRepository<M>

Memory backed implementation of MetricRepository that uses a ConcurrentMap

Author:

Luke Taylor

Constructor Summary

Constructors

Constructor and Description
InMemoryMetricRepository()

Method Summary

Methods

Modifier and Type	Method and Description
long	count()
protected abstract M	create(java.lang.String name)
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)
protected M	getOrCreate(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

Constructor Detail

InMemoryMetricRepository

public InMemoryMetricRepository()

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>

getOrCreate

protected M getOrCreate(java.lang.String name)

create

protected abstract M create(java.lang.String name)