org.gridgain.grid.kernal.processors.cache

Interface GridCachePreloader<K,V>

All Known Implementing Classes:

GridCachePreloaderAdapter, GridDhtPreloader

public interface GridCachePreloader<K,V>

Cache preloader that is responsible for loading cache entries either from remote nodes (for distributed cache) or anywhere else at cache startup.

Method Summary

Methods

Modifier and Type	Method and Description
void	forcePreload() Force preload process.
void	onKernalStart() Kernal start callback.
void	onKernalStop() Kernal stop callback.
GridPredicate<GridCacheEntryInfo<K,V>>	preloadPredicate()
void	preloadPredicate(GridPredicate<GridCacheEntryInfo<K,V>> p)
GridFuture<Object>	request(Collection<? extends K> keys, long topVer) Requests that preloader sends the request for the key.
void	start() Starts preloading.
GridFuture<?>	startFuture()
void	stop() Stops preloading.
GridFuture<?>	syncFuture()
void	unwindUndeploys() Unwinds undeploys.

Method Detail

start

void start()
           throws GridException

Starts preloading.

Throws:

GridException - If start failed.

stop

void stop()

Stops preloading.

onKernalStart

void onKernalStart()
                   throws GridException

Kernal start callback.

Throws:

GridException - If failed.

onKernalStop

void onKernalStop()

Kernal stop callback.

preloadPredicate

void preloadPredicate(GridPredicate<GridCacheEntryInfo<K,V>> p)

Parameters:

p - Preload predicate.

preloadPredicate

GridPredicate<GridCacheEntryInfo<K,V>> preloadPredicate()

Returns:

Preload predicate. If not null, will evaluate each preloaded entry during send and receive, and if predicate evaluates to false, entry will be skipped.

startFuture

GridFuture<?> startFuture()

Returns:

Future which will complete when preloader is safe to use.

syncFuture

GridFuture<?> syncFuture()

Returns:

Future which will complete when preloading is finished.

request

GridFuture<Object> request(Collection<? extends K> keys,
                         long topVer)

Requests that preloader sends the request for the key.

Parameters:

keys - Keys to request.

topVer - Topology version, -1 if not required.

Returns:

Future to complete when all keys are preloaded.

forcePreload

void forcePreload()

Force preload process.

unwindUndeploys

void unwindUndeploys()

Unwinds undeploys.