@ThreadSafe public class RemoteStore<K,V> extends Object implements org.infinispan.persistence.spi.AdvancedLoadWriteStore<K,V>, org.infinispan.persistence.spi.FlagAffectedStore<K,V>
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) |
boolean |
isAvailable() |
org.infinispan.marshall.core.MarshalledEntry<K,V> |
load(Object key) |
org.reactivestreams.Publisher<org.infinispan.marshall.core.MarshalledEntry<K,V>> |
publishEntries(Predicate<? super K> filter,
boolean fetchValue,
boolean fetchMetadata) |
io.reactivex.Flowable<K> |
publishKeys(Predicate<? super K> filter) |
void |
purge(Executor threadPool,
org.infinispan.persistence.spi.AdvancedCacheWriter.PurgeListener task) |
void |
setInternalCacheEntryFactory(org.infinispan.container.impl.InternalEntryFactory iceFactory) |
boolean |
shouldWrite(long commandFlags) |
int |
size() |
void |
start() |
void |
stop() |
void |
write(org.infinispan.marshall.core.MarshalledEntry entry) |
void |
writeBatch(Iterable<org.infinispan.marshall.core.MarshalledEntry<? extends K,? extends V>> marshalledEntries) |
public void init(org.infinispan.persistence.spi.InitializationContext ctx)
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 boolean isAvailable()
public org.infinispan.marshall.core.MarshalledEntry<K,V> load(Object key) throws org.infinispan.persistence.spi.PersistenceException
public boolean contains(Object key) throws org.infinispan.persistence.spi.PersistenceException
public org.reactivestreams.Publisher<org.infinispan.marshall.core.MarshalledEntry<K,V>> publishEntries(Predicate<? super K> filter, boolean fetchValue, boolean fetchMetadata)
public int size()
public void purge(Executor threadPool, org.infinispan.persistence.spi.AdvancedCacheWriter.PurgeListener task)
public void write(org.infinispan.marshall.core.MarshalledEntry entry) throws org.infinispan.persistence.spi.PersistenceException
public void writeBatch(Iterable<org.infinispan.marshall.core.MarshalledEntry<? extends K,? extends V>> marshalledEntries)
public void clear() throws org.infinispan.persistence.spi.PersistenceException
public boolean delete(Object key) throws org.infinispan.persistence.spi.PersistenceException
public void setInternalCacheEntryFactory(org.infinispan.container.impl.InternalEntryFactory iceFactory)
public RemoteStoreConfiguration getConfiguration()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.