Class CacheWarmer

java.lang.Object

com.loomcache.server.cache.CacheWarmer

public class CacheWarmer
extends Object

Warms cache from various sources for fast startup. Supports snapshot-based warming, peer-based warming, and external loader warming. Uses virtual threads via StructuredTaskScope for parallel warming.

Constructor Summary

Constructors

Constructor	Description
CacheWarmer(DataStructureRegistry registry, @Nullable WarmingConfig config, @Nullable WarmingListener listener, @Nullable AccessTracker accessTracker)	Create a CacheWarmer with the given configuration.

Method Summary

Modifier and Type	Method	Description
WarmingResult	preload(PreloadPolicy policy, CacheLoader loader)	Preload cache based on a preload policy.
WarmingResult	warmFromLoader(CacheLoader loader, List<String> keys)	Warm cache from an external loader using parallel virtual threads.
WarmingResult	warmFromPeer(String peerAddress)	Warm cache from a running peer node.
WarmingResult	warmFromSnapshot(byte[] snapshotData)	Warm cache from a saved snapshot (byte array).

Methods inherited from class Object

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

Constructor Details

CacheWarmer

public CacheWarmer(DataStructureRegistry registry,
 @Nullable WarmingConfig config,
 @Nullable WarmingListener listener,
 @Nullable AccessTracker accessTracker)

Create a CacheWarmer with the given configuration.

Method Details

warmFromSnapshot

public WarmingResult warmFromSnapshot(byte[] snapshotData)
                               throws Exception

Warm cache from a saved snapshot (byte array).

Throws:

Exception

warmFromPeer

public WarmingResult warmFromPeer(String peerAddress)
                           throws Exception

Warm cache from a running peer node. Makes a request to another cluster node to retrieve state.

Throws:

Exception

warmFromLoader

public WarmingResult warmFromLoader(CacheLoader loader,
 List<String> keys)
                             throws Exception

Warm cache from an external loader using parallel virtual threads.

Throws:

Exception

preload

public WarmingResult preload(PreloadPolicy policy,
 CacheLoader loader)
                      throws Exception

Preload cache based on a preload policy.

Throws:

Exception