Class CacheWriterIntegration<K,V>

java.lang.Object

com.loomcache.server.jcache.CacheWriterIntegration<K,V>

Type Parameters:

K - the key type

V - the value type

public class CacheWriterIntegration<K,V>
extends Object

Manages write-through and write-behind cache strategies.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	CacheWriterIntegration.BackingStoreWriter<K,V>
static final record	CacheWriterIntegration.WriteBehindConfig	Configuration for write-behind mode.
static final record	CacheWriterIntegration.WriteBehindStats	Write-behind statistics snapshot.

Constructor Summary

Constructors

Constructor	Description
CacheWriterIntegration(CacheWriterIntegration.BackingStoreWriter<K,V> writer)	Create a write-through integration.
CacheWriterIntegration(CacheWriterIntegration.BackingStoreWriter<K,V> writer, CacheWriterIntegration.WriteBehindConfig config)	Create a write-behind integration.

Method Summary

Modifier and Type	Method	Description
void	close()	Close and flush pending writes.
static <K,V> CacheWriterIntegration<K,V>	fromMapStore(MapStore<K,V> mapStore, MapStoreConfig config)	Bridge factory: wire a MapStore through the JCache write-through / write-behind machinery by wrapping it in a MapStoreBackedCacheWriter.
@Nullable CacheWriterIntegration.WriteBehindStats	getWriteBehindStats()	Get write-behind statistics.
void	write(K key, V value)	Write a key-value pair.

Methods inherited from class Object

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

Constructor Details

CacheWriterIntegration

public CacheWriterIntegration(CacheWriterIntegration.BackingStoreWriter<K,V> writer)

Create a write-through integration.

CacheWriterIntegration

public CacheWriterIntegration(CacheWriterIntegration.BackingStoreWriter<K,V> writer,
 CacheWriterIntegration.WriteBehindConfig config)

Create a write-behind integration.

Method Details

fromMapStore

public static <K,V> CacheWriterIntegration<K,V> fromMapStore(MapStore<K,V> mapStore,
 MapStoreConfig config)

Bridge factory: wire a MapStore through the JCache write-through / write-behind machinery by wrapping it in a MapStoreBackedCacheWriter.

When the supplied MapStoreConfig is write-behind, JCache's scheduler is used — the MapStoreConfig's writeBatchSize and writeDelay control its batching (with a fixed maxRetries of 3). When the config is write-through, the returned integration is synchronous.

write

public void write(K key,
 V value)
           throws Exception

Write a key-value pair.

Throws:

Exception

getWriteBehindStats

public @Nullable CacheWriterIntegration.WriteBehindStats getWriteBehindStats()

Get write-behind statistics.

close

public void close()

Close and flush pending writes.