Package org.nuxeo.ecm.core.transientstore

Class SimpleTransientStore

java.lang.Object

org.nuxeo.ecm.core.transientstore.AbstractTransientStore

org.nuxeo.ecm.core.transientstore.SimpleTransientStore

All Implemented Interfaces:

TransientStore, TransientStoreProvider

public class SimpleTransientStore
extends AbstractTransientStore

Default implementation (i.e., not cluster aware) of the TransientStore. Uses StorageEntry as a representation of an entry in the store.

Since:

7.2

Field Summary

Fields

Modifier and Type	Field	Description
protected com.google.common.cache.Cache<String,Serializable>	l1Cache
protected com.google.common.cache.Cache<String,Serializable>	l2Cache
protected Log	log
protected AtomicLong	storageSize

Fields inherited from class org.nuxeo.ecm.core.transientstore.AbstractTransientStore

cacheDir, config

Constructor Summary

Constructors

Constructor	Description
SimpleTransientStore()

Method Summary

Modifier and Type	Method	Description
protected long	decrementStorageSize(long size)
boolean	exists(String key)	Returns true if an entry exists with the given key.
List<Blob>	getBlobs(String key)	Gets the blobs associated with the entry with the given key.
com.google.common.cache.Cache<String,Serializable>	getL1Cache()
com.google.common.cache.Cache<String,Serializable>	getL2Cache()
Serializable	getParameter(String key, String parameter)	Gets the value of parameter in the entry with the given key.
Map<String,Serializable>	getParameters(String key)	Gets values of the parameters in the entry with the given key.
long	getSize(String key)	Returns the size of the blobs associated with the entry with the given key or -1 if entry does not exist.
protected StorageEntry	getStorageEntry(String key)	Returns the StorageEntry representing the entry with the given key or null if it doesn't exist.
long	getStorageSize()	Returns the size (in bytes) of the disk storage used for blobs.
protected long	incrementStorageSize(long size)
void	init(TransientStoreConfig config)	Initializes the store from the given config.
boolean	isCompleted(String key)	Returns true if the entry with the given key is ready.
Set<String>	keySet()	Returns the set of keys for all entries.
Stream<String>	keyStream()	Returns a Stream of keys for all entries.
protected void	persistBlobs(String key, long sizeOfBlobs, List<Map<String,String>> blobInfos)	Updates the total storage size and the storage size of the entry with the given key according to sizeOfBlobs and stores the blob information in this entry.
void	putParameter(String key, String parameter, Serializable value)	Sets parameter to value in the entry with the given key.
void	putParameters(String key, Map<String,Serializable> parameters)	Puts parameters in the entry with the given key.
protected void	putStorageEntry(String key, StorageEntry entry)	Stores the given entry with the given key.
void	release(String key)	Informs the store that the entry with the given key can be released if TTL or GC parameters require to do some cleanup.
protected void	removeAllEntries()
protected void	removeEntry(String key)
void	setCompleted(String key, boolean completed)	Marks the entry with the given key as ready.
protected void	setStorageSize(long newSize)	Sets the size of the disk storage in bytes.
void	shutdown()	Shuts down the store.

Methods inherited from class org.nuxeo.ecm.core.transientstore.AbstractTransientStore

doGC, getCacheDir, getCachingDirectory, getCachingDirName, getFilePathSize, getKeyCachingDirName, getSizeOfBlobs, loadBlobs, putBlobs, remove, removeAll, removeBlobs, storeBlobs

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.ecm.core.transientstore.api.TransientStoreProvider

getStorageSizeMB

Field Detail

log

protected Log log

l1Cache

protected com.google.common.cache.Cache<String,Serializable> l1Cache

l2Cache

protected com.google.common.cache.Cache<String,Serializable> l2Cache

storageSize

protected AtomicLong storageSize

Constructor Detail

SimpleTransientStore

public SimpleTransientStore()

Method Detail

init

public void init(TransientStoreConfig config)

Description copied from interface: TransientStoreProvider

Initializes the store from the given config.

Specified by:

init in interface TransientStoreProvider

Overrides:

init in class AbstractTransientStore

shutdown

public void shutdown()

Description copied from interface: TransientStoreProvider

Shuts down the store.

Specified by:

shutdown in interface TransientStoreProvider

Specified by:

shutdown in class AbstractTransientStore

exists

public boolean exists(String key)

Description copied from interface: TransientStore

Returns true if an entry exists with the given key.

Specified by:

exists in interface TransientStore

Specified by:

exists in class AbstractTransientStore

keySet

public Set<String> keySet()

Description copied from interface: TransientStoreProvider

Returns the set of keys for all entries.

keyStream

public Stream<String> keyStream()

Description copied from interface: TransientStoreProvider

Returns a Stream of keys for all entries.

putParameter

public void putParameter(String key,
                         String parameter,
                         Serializable value)

Description copied from interface: TransientStore

Sets parameter to value in the entry with the given key.

If entry does not exist a new entry is created. If parameter already exists in the entry it is overwritten.

Specified by:

putParameter in interface TransientStore

Specified by:

putParameter in class AbstractTransientStore

getParameter

public Serializable getParameter(String key,
                                 String parameter)

Description copied from interface: TransientStore

Gets the value of parameter in the entry with the given key.

Returns null if entry or parameter does not exist.

Specified by:

getParameter in interface TransientStore

Specified by:

getParameter in class AbstractTransientStore

putParameters

public void putParameters(String key,
                          Map<String,Serializable> parameters)

Description copied from interface: TransientStore

Puts parameters in the entry with the given key. Overwrites any existing parameter in the entry.

If entry does not exist a new entry is created.

Specified by:

putParameters in interface TransientStore

Specified by:

putParameters in class AbstractTransientStore

getParameters

public Map<String,Serializable> getParameters(String key)

Description copied from interface: TransientStore

Gets values of the parameters in the entry with the given key.

Returns null if entry does not exist.

Specified by:

getParameters in interface TransientStore

Specified by:

getParameters in class AbstractTransientStore

getBlobs

public List<Blob> getBlobs(String key)

Description copied from interface: TransientStore

Gets the blobs associated with the entry with the given key.

Returns null if entry does not exist.

Specified by:

getBlobs in interface TransientStore

Specified by:

getBlobs in class AbstractTransientStore

getSize

public long getSize(String key)

Description copied from interface: TransientStore

Returns the size of the blobs associated with the entry with the given key or -1 if entry does not exist.

Specified by:

getSize in interface TransientStore

Specified by:

getSize in class AbstractTransientStore

isCompleted

public boolean isCompleted(String key)

Description copied from interface: TransientStore

Returns true if the entry with the given key is ready.

Specified by:

isCompleted in interface TransientStore

Specified by:

isCompleted in class AbstractTransientStore

setCompleted

public void setCompleted(String key,
                         boolean completed)

Description copied from interface: TransientStore

Marks the entry with the given key as ready.

If entry does not exist a new entry is created.

Specified by:

setCompleted in interface TransientStore

Specified by:

setCompleted in class AbstractTransientStore

release

public void release(String key)

Description copied from interface: TransientStore

Informs the store that the entry with the given key can be released if TTL or GC parameters require to do some cleanup.

Has no effect if entry does not exist.

Specified by:

release in interface TransientStore

Specified by:

release in class AbstractTransientStore

persistBlobs

protected void persistBlobs(String key,
                            long sizeOfBlobs,
                            List<Map<String,String>> blobInfos)

Description copied from class: AbstractTransientStore

Updates the total storage size and the storage size of the entry with the given key according to sizeOfBlobs and stores the blob information in this entry.

Specified by:

persistBlobs in class AbstractTransientStore

getStorageSize

public long getStorageSize()

Description copied from interface: TransientStoreProvider

Returns the size (in bytes) of the disk storage used for blobs.

Returns:

the number of bytes used by stored blobs

setStorageSize

protected void setStorageSize(long newSize)

Description copied from class: AbstractTransientStore

Sets the size of the disk storage in bytes.

Specified by:

setStorageSize in class AbstractTransientStore

incrementStorageSize

protected long incrementStorageSize(long size)

Specified by:

incrementStorageSize in class AbstractTransientStore

decrementStorageSize

protected long decrementStorageSize(long size)

Specified by:

decrementStorageSize in class AbstractTransientStore

removeEntry

protected void removeEntry(String key)

Specified by:

removeEntry in class AbstractTransientStore

removeAllEntries

protected void removeAllEntries()

Specified by:

removeAllEntries in class AbstractTransientStore

getL1Cache

public com.google.common.cache.Cache<String,Serializable> getL1Cache()

getL2Cache

public com.google.common.cache.Cache<String,Serializable> getL2Cache()

getStorageEntry

protected StorageEntry getStorageEntry(String key)

Returns the StorageEntry representing the entry with the given key or null if it doesn't exist.

putStorageEntry

protected void putStorageEntry(String key,
                               StorageEntry entry)

Stores the given entry with the given key.

If an entry exists with the given key it is overwritten.