@ThreadSafe public class RemoteStore extends Object implements org.infinispan.persistence.spi.AdvancedLoadWriteStore, org.infinispan.persistence.spi.FlagAffectedStore
RemoteStoreConfiguration
,
Hotrod Java ClientModifier and Type | Field and Description |
---|---|
protected org.infinispan.persistence.spi.InitializationContext |
ctx |
Constructor and Description |
---|
RemoteStore() |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
boolean |
contains(Object key) |
boolean |
delete(Object key) |
RemoteStoreConfiguration |
getConfiguration() |
org.infinispan.client.hotrod.RemoteCache<Object,Object> |
getRemoteCache() |
void |
init(org.infinispan.persistence.spi.InitializationContext ctx) |
org.infinispan.marshall.core.MarshalledEntry |
load(Object key) |
void |
process(org.infinispan.filter.KeyFilter filter,
org.infinispan.persistence.spi.AdvancedCacheLoader.CacheLoaderTask task,
Executor executor,
boolean fetchValue,
boolean fetchMetadata) |
void |
purge(Executor threadPool,
org.infinispan.persistence.spi.AdvancedCacheWriter.PurgeListener task) |
void |
setInternalCacheEntryFactory(org.infinispan.container.InternalEntryFactory iceFactory) |
boolean |
shouldWrite(Set commandFlags) |
int |
size() |
void |
start() |
void |
stop() |
void |
write(org.infinispan.marshall.core.MarshalledEntry entry) |
public void init(org.infinispan.persistence.spi.InitializationContext ctx)
init
in interface org.infinispan.persistence.spi.CacheLoader
init
in interface org.infinispan.persistence.spi.CacheWriter
public void start() throws org.infinispan.persistence.spi.PersistenceException
start
in interface org.infinispan.commons.api.Lifecycle
org.infinispan.persistence.spi.PersistenceException
public void stop() throws org.infinispan.persistence.spi.PersistenceException
stop
in interface org.infinispan.commons.api.Lifecycle
org.infinispan.persistence.spi.PersistenceException
public org.infinispan.marshall.core.MarshalledEntry load(Object key) throws org.infinispan.persistence.spi.PersistenceException
load
in interface org.infinispan.persistence.spi.CacheLoader
org.infinispan.persistence.spi.PersistenceException
public boolean contains(Object key) throws org.infinispan.persistence.spi.PersistenceException
contains
in interface org.infinispan.persistence.spi.CacheLoader
org.infinispan.persistence.spi.PersistenceException
public void process(org.infinispan.filter.KeyFilter filter, org.infinispan.persistence.spi.AdvancedCacheLoader.CacheLoaderTask task, Executor executor, boolean fetchValue, boolean fetchMetadata)
process
in interface org.infinispan.persistence.spi.AdvancedCacheLoader
public int size()
size
in interface org.infinispan.persistence.spi.AdvancedCacheLoader
public void purge(Executor threadPool, org.infinispan.persistence.spi.AdvancedCacheWriter.PurgeListener task)
purge
in interface org.infinispan.persistence.spi.AdvancedCacheWriter
public void write(org.infinispan.marshall.core.MarshalledEntry entry) throws org.infinispan.persistence.spi.PersistenceException
write
in interface org.infinispan.persistence.spi.CacheWriter
org.infinispan.persistence.spi.PersistenceException
public void clear() throws org.infinispan.persistence.spi.PersistenceException
clear
in interface org.infinispan.persistence.spi.AdvancedCacheWriter
org.infinispan.persistence.spi.PersistenceException
public boolean delete(Object key) throws org.infinispan.persistence.spi.PersistenceException
delete
in interface org.infinispan.persistence.spi.CacheWriter
org.infinispan.persistence.spi.PersistenceException
public void setInternalCacheEntryFactory(org.infinispan.container.InternalEntryFactory iceFactory)
public RemoteStoreConfiguration getConfiguration()
public boolean shouldWrite(Set commandFlags)
shouldWrite
in interface org.infinispan.persistence.spi.FlagAffectedStore
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.