Package io.quarkus.cache.infinispan.runtime

Class InfinispanCacheImpl

java.lang.Object

io.quarkus.cache.runtime.AbstractCache

io.quarkus.cache.infinispan.runtime.InfinispanCacheImpl

All Implemented Interfaces:

io.quarkus.cache.Cache

public class InfinispanCacheImpl
extends io.quarkus.cache.runtime.AbstractCache
implements io.quarkus.cache.Cache

This class is an internal Quarkus cache implementation using Infinispan. Do not use it explicitly from your Quarkus application.

Field Summary

Fields inherited from class io.quarkus.cache.runtime.AbstractCache

NULL_KEYS_NOT_SUPPORTED_MSG

Constructor Summary

Constructors

Constructor	Description
InfinispanCacheImpl(InfinispanCacheInfo cacheInfo, Optional<String> infinispanClientName)
InfinispanCacheImpl(InfinispanCacheInfo cacheInfo, org.infinispan.client.hotrod.RemoteCache remoteCache)

Method Summary

Modifier and Type	Method	Description
<T extends io.quarkus.cache.Cache> T	as(Class<T> type)
<K, V> io.smallrye.mutiny.Uni<V>	get(K key, Function<K,V> valueLoader)
<K, V> io.smallrye.mutiny.Uni<V>	getAsync(K key, Function<K,io.smallrye.mutiny.Uni<V>> valueLoader)
Object	getDefaultKey()
String	getName()
io.smallrye.mutiny.Uni<Void>	invalidate(Object key)
io.smallrye.mutiny.Uni<Void>	invalidateAll()
io.smallrye.mutiny.Uni<Void>	invalidateIf(Predicate<Object> predicate)

Methods inherited from class java.lang.Object

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

Constructor Details

InfinispanCacheImpl

public InfinispanCacheImpl(InfinispanCacheInfo cacheInfo,
 org.infinispan.client.hotrod.RemoteCache remoteCache)

InfinispanCacheImpl

public InfinispanCacheImpl(InfinispanCacheInfo cacheInfo,
 Optional<String> infinispanClientName)

Method Details

getName

public String getName()

Specified by:

getName in interface io.quarkus.cache.Cache

getDefaultKey

public Object getDefaultKey()

Specified by:

getDefaultKey in interface io.quarkus.cache.Cache

Overrides:

getDefaultKey in class io.quarkus.cache.runtime.AbstractCache

get

public <K,
V> io.smallrye.mutiny.Uni<V> get(K key,
 Function<K,V> valueLoader)

Specified by:

get in interface io.quarkus.cache.Cache

getAsync

public <K,
V> io.smallrye.mutiny.Uni<V> getAsync(K key,
 Function<K,io.smallrye.mutiny.Uni<V>> valueLoader)

Specified by:

getAsync in interface io.quarkus.cache.Cache

invalidate

public io.smallrye.mutiny.Uni<Void> invalidate(Object key)

Specified by:

invalidate in interface io.quarkus.cache.Cache

invalidateAll

public io.smallrye.mutiny.Uni<Void> invalidateAll()

Specified by:

invalidateAll in interface io.quarkus.cache.Cache

invalidateIf

public io.smallrye.mutiny.Uni<Void> invalidateIf(Predicate<Object> predicate)

Specified by:

invalidateIf in interface io.quarkus.cache.Cache

as

public <T extends io.quarkus.cache.Cache> T as(Class<T> type)

Specified by:

as in interface io.quarkus.cache.Cache

Overrides:

as in class io.quarkus.cache.runtime.AbstractCache