Package dev.enola.data

Class MemoryRepositoryRW<T>

java.lang.Object

dev.enola.data.MemoryRepositoryRW<T>

All Implemented Interfaces:

Provider<String,T>, ProviderFromIRI<T>, Repository<T>, RepositoryRW<T>, Store<T>

Direct Known Subclasses:

ThingMemoryRepositoryRW

@ThreadSafe
public abstract class MemoryRepositoryRW<T>
extends Object
implements RepositoryRW<T>

MemoryRepositoryRW is an in-memory RepositoryRW implemented using a ConcurrentHashMap. It is suitable for us by multiple concurrent threads.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MemoryRepositoryRW(com.google.common.collect.ImmutableList<Trigger<? extends T>> triggers)

Method Summary

Modifier and Type	Method	Description
T	get(String iri)	Get.
protected abstract String	getIRI(T value)
Iterable<T>	list()	list() returns Ts directly (not just the IRIs, like Repository.listIRI()).
Iterable<String>	listIRI()
protected Map<String,T>	map()
dev.enola.data.AbstractMapRepositoryRW<T>	store(T item)	Store a T.
protected void	trigger(T existing, T updated)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface dev.enola.data.ProviderFromIRI

get

Methods inherited from interface dev.enola.data.Repository

list, listIRI, stream

Methods inherited from interface dev.enola.data.Store

store, storeAll

Constructor Details

MemoryRepositoryRW

protected MemoryRepositoryRW(com.google.common.collect.ImmutableList<Trigger<? extends T>> triggers)

Method Details

map

protected Map<String,T> map()

getIRI

protected abstract String getIRI(T value)

store

@CanIgnoreReturnValue
public dev.enola.data.AbstractMapRepositoryRW<T> store(T item)

Description copied from interface: Store

Store a T.

If this store already has this T, then it's replaced (entirely, not "merged").

Specified by:

store in interface Store<T>

list

public Iterable<T> list()

Description copied from interface: Repository

list() returns Ts directly (not just the IRIs, like Repository.listIRI()).

This default implementation here just combines Repository.listIRI() and ProviderFromIRI.get(String). Your subclass may be able to provide a more efficient and more "direct" implementation?

Specified by:

list in interface Repository<T>

listIRI

public Iterable<String> listIRI()

Specified by:

listIRI in interface Repository<T>

get

public T get(String iri)

Description copied from interface: Provider

Get.

Specified by:

get in interface Provider<String,T>

Specified by:

get in interface ProviderFromIRI<T>

Parameters:

iri - Key, never null

Returns:

value, or null if there is no Value for the given key

trigger

protected void trigger(T existing,
 T updated)