Package org.infinispan.persistence.rest

Class RestStore<K,V>

java.lang.Object

org.infinispan.persistence.rest.RestStore<K,V>

All Implemented Interfaces:

Lifecycle, AdvancedCacheLoader<K,V>, AdvancedCacheWriter<K,V>, AdvancedLoadWriteStore<K,V>, CacheLoader<K,V>, CacheWriter<K,V>, ExternalStore<K,V>

@ThreadSafe
public class RestStore<K,V>
extends Object
implements AdvancedLoadWriteStore<K,V>

Deprecated.

This cache store will be changed to only implement CacheLoader

RestStore.

Since:

6.0

Author:

Tristan Tarrant

Nested Class Summary

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.AdvancedCacheLoader

AdvancedCacheLoader.CacheLoaderTask<K,V>, AdvancedCacheLoader.TaskContext

Nested classes/interfaces inherited from interface org.infinispan.persistence.spi.AdvancedCacheWriter

AdvancedCacheWriter.PurgeListener<K>

Constructor Summary

Constructors

Constructor	Description
RestStore()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	clear()	Deprecated. Removes all the data from the storage.
boolean	contains(Object o)	Deprecated. Returns true if the storage contains an entry associated with the given key.
boolean	delete(Object key)	Deprecated.
io.reactivex.Flowable<MarshallableEntry<K,V>>	entryPublisher(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)	Deprecated. Publishes all entries from this store.
void	init(InitializationContext initializationContext)	Deprecated. Used to initialize a cache loader.
boolean	isAvailable()	Deprecated.
MarshallableEntry<K,V>	loadEntry(Object key)	Deprecated. Fetches an entry from the storage.
io.reactivex.Flowable<K>	publishKeys(Predicate<? super K> filter)	Deprecated. Publishes all the keys from this store.
void	purge(Executor executor, AdvancedCacheWriter.PurgeListener<? super K> purgeListener)	Deprecated. Using the thread in the pool, removed all the expired data from the persistence storage.
int	size()	Deprecated. Returns the number of elements in the store.
void	start()	Deprecated. Invoked on component start
void	stop()	Deprecated. Invoked on component stop
void	write(MarshallableEntry<? extends K,? extends V> entry)	Deprecated. Persists the entry to the storage.

Methods inherited from interface org.infinispan.persistence.spi.AdvancedCacheLoader

process, publishEntries

Methods inherited from interface org.infinispan.persistence.spi.CacheLoader

load

Methods inherited from interface org.infinispan.persistence.spi.CacheWriter

bulkUpdate, deleteBatch, write, writeBatch

Methods inherited from interface org.infinispan.persistence.spi.ExternalStore

destroy

Constructor Detail

RestStore

public RestStore()

Deprecated.

Method Detail

init

public void init(InitializationContext initializationContext)

Deprecated.

Description copied from interface: CacheLoader

Used to initialize a cache loader. Typically invoked by the PersistenceManager when setting up cache loaders.

Specified by:

init in interface CacheLoader<K,V>

Specified by:

init in interface CacheWriter<K,V>

start

public void start()

Deprecated.

Description copied from interface: Lifecycle

Invoked on component start

Specified by:

start in interface Lifecycle

stop

public void stop()

Deprecated.

Description copied from interface: Lifecycle

Invoked on component stop

Specified by:

stop in interface Lifecycle

isAvailable

public boolean isAvailable()

Deprecated.

Specified by:

isAvailable in interface CacheLoader<K,V>

Specified by:

isAvailable in interface CacheWriter<K,V>

Specified by:

isAvailable in interface ExternalStore<K,V>

Returns:

true if the writer can be connected to, otherwise false

write

public void write(MarshallableEntry<? extends K,? extends V> entry)

Deprecated.

Description copied from interface: CacheWriter

Persists the entry to the storage.

Specified by:

write in interface CacheWriter<K,V>

See Also:

MarshallableEntry

clear

public void clear()

Deprecated.

Description copied from interface: AdvancedCacheWriter

Removes all the data from the storage.

Specified by:

clear in interface AdvancedCacheWriter<K,V>

delete

public boolean delete(Object key)

Deprecated.

Specified by:

delete in interface CacheWriter<K,V>

Returns:

true if the entry existed in the persistent store and it was deleted.

loadEntry

public MarshallableEntry<K,V> loadEntry(Object key)

Deprecated.

Description copied from interface: CacheLoader

Fetches an entry from the storage. If a MarshallableEntry needs to be created here, InitializationContext.getMarshallableEntryFactory() ()} and InitializationContext.getByteBufferFactory() should be used.

Specified by:

loadEntry in interface CacheLoader<K,V>

Returns:

the entry, or null if the entry does not exist

publishKeys

public io.reactivex.Flowable<K> publishKeys(Predicate<? super K> filter)

Deprecated.

Description copied from interface: AdvancedCacheLoader

Publishes all the keys from this store. The given publisher can be used by as many Subscribers as desired. Keys are not retrieved until a given Subscriber requests them from the Subscription.

Stores will return only non expired keys

Specified by:

publishKeys in interface AdvancedCacheLoader<K,V>

Parameters:

filter - a filter - null is treated as allowing all entries

Returns:

a publisher that will provide the keys from the store

entryPublisher

public io.reactivex.Flowable<MarshallableEntry<K,V>> entryPublisher(Predicate<? super K> filter,
                                                                          boolean fetchValue,
                                                                          boolean fetchMetadata)

Deprecated.

Description copied from interface: AdvancedCacheLoader

Publishes all entries from this store. The given publisher can be used by as many Subscribers as desired. Entries are not retrieved until a given Subscriber requests them from the Subscription.

If fetchMetadata is true this store must guarantee to not return any expired entries.

Specified by:

entryPublisher in interface AdvancedCacheLoader<K,V>

Parameters:

filter - a filter - null is treated as allowing all entries

fetchValue - whether or not to fetch the value from the persistent store. E.g. if the iteration is intended only over the key set, no point fetching the values from the persistent store as well

fetchMetadata - whether or not to fetch the metadata from the persistent store. E.g. if the iteration is intended only ove the key set, then no point fetching the metadata from the persistent store as well

Returns:

a publisher that will provide the entries from the store

purge

public void purge(Executor executor,
                  AdvancedCacheWriter.PurgeListener<? super K> purgeListener)

Deprecated.

Description copied from interface: AdvancedCacheWriter

Using the thread in the pool, removed all the expired data from the persistence storage. For each removed entry, the supplied listener is invoked.

When this method returns all entries will be purged and no tasks will be running due to this loader in the provided executor. If however an exception is thrown there could be tasks still pending or running in the executor.

Specified by:

purge in interface AdvancedCacheWriter<K,V>

size

public int size()

Deprecated.

Description copied from interface: AdvancedCacheLoader

Returns the number of elements in the store.

Specified by:

size in interface AdvancedCacheLoader<K,V>

contains

public boolean contains(Object o)

Deprecated.

Description copied from interface: CacheLoader

Returns true if the storage contains an entry associated with the given key.

Specified by:

contains in interface CacheLoader<K,V>