Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.functional | |
org.infinispan.functional |
Functional API package
|
org.infinispan.functional.impl | |
org.infinispan.marshall.core |
Modifier and Type | Method and Description |
---|---|
<K,V,R> ReadOnlyKeyCommand<K,V,R> |
CommandsFactory.buildReadOnlyKeyCommand(Object key,
Function<EntryView.ReadEntryView<K,V>,R> f,
int segment,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
<K,V,R> ReadOnlyKeyCommand<K,V,R> |
CommandsFactoryImpl.buildReadOnlyKeyCommand(Object key,
Function<EntryView.ReadEntryView<K,V>,R> f,
int segment,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
<K,V,R> ReadOnlyManyCommand<K,V,R> |
CommandsFactory.buildReadOnlyManyCommand(Collection<?> keys,
Function<EntryView.ReadEntryView<K,V>,R> f,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
<K,V,R> ReadOnlyManyCommand<K,V,R> |
CommandsFactoryImpl.buildReadOnlyManyCommand(Collection<?> keys,
Function<EntryView.ReadEntryView<K,V>,R> f,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
<K,V,R> TxReadOnlyKeyCommand<K,V,R> |
CommandsFactory.buildTxReadOnlyKeyCommand(Object key,
Function<EntryView.ReadEntryView<K,V>,R> f,
List<Mutation<K,V,?>> mutations,
int segment,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
<K,V,R> TxReadOnlyKeyCommand<K,V,R> |
CommandsFactoryImpl.buildTxReadOnlyKeyCommand(Object key,
Function<EntryView.ReadEntryView<K,V>,R> f,
List<Mutation<K,V,?>> mutations,
int segment,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
Modifier and Type | Field and Description |
---|---|
protected Function<EntryView.ReadEntryView<K,V>,R> |
ReadOnlyKeyCommand.f |
protected Function<EntryView.ReadEntryView<K,V>,R> |
ReadOnlyManyCommand.f |
Modifier and Type | Method and Description |
---|---|
Function<EntryView.ReadEntryView<K,V>,R> |
ReadOnlyKeyCommand.getFunction() |
Function<EntryView.ReadEntryView<K,V>,R> |
ReadOnlyManyCommand.getFunction() |
Constructor and Description |
---|
ReadOnlyKeyCommand(Object key,
Function<EntryView.ReadEntryView<K,V>,R> f,
int segment,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
ReadOnlyManyCommand(Collection<?> keys,
Function<EntryView.ReadEntryView<K,V>,R> f,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
TxReadOnlyKeyCommand(Object key,
Function<EntryView.ReadEntryView<K,V>,R> f,
List<Mutation<K,V,?>> mutations,
int segment,
Params params,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
Modifier and Type | Interface and Description |
---|---|
static interface |
EntryView.ReadWriteEntryView<K,V>
Expose information about a cache entry potentially associated with a key
in the functional map, and allows that cache entry to be written with
new value and/or new metadata parameters.
|
Modifier and Type | Method and Description |
---|---|
Traversable<EntryView.ReadEntryView<K,V>> |
FunctionalMap.ReadOnlyMap.entries()
Provides a
Traversable that allows clients to navigate all cached entries. |
Modifier and Type | Method and Description |
---|---|
default void |
Listeners.ReadWriteListeners.ReadWriteListener.onCreate(EntryView.ReadEntryView<K,V> created)
Entry created event callback that receives a
EntryView.ReadEntryView
of the created entry. |
default void |
Listeners.ReadWriteListeners.ReadWriteListener.onModify(EntryView.ReadEntryView<K,V> before,
EntryView.ReadEntryView<K,V> after)
Entry modify/update event callback that receives
EntryView.ReadEntryView
of the previous entry as first parameter, and the EntryView.ReadEntryView
of the new entry. |
default void |
Listeners.ReadWriteListeners.ReadWriteListener.onModify(EntryView.ReadEntryView<K,V> before,
EntryView.ReadEntryView<K,V> after)
Entry modify/update event callback that receives
EntryView.ReadEntryView
of the previous entry as first parameter, and the EntryView.ReadEntryView
of the new entry. |
default void |
Listeners.ReadWriteListeners.ReadWriteListener.onRemove(EntryView.ReadEntryView<K,V> removed)
Entry removed event callback that receives a
EntryView.ReadEntryView
of the removed entry. |
void |
Listeners.WriteListeners.WriteListener.onWrite(EntryView.ReadEntryView<K,V> write)
Entry write event callback that receives a
EntryView.ReadEntryView
of the written entry. |
Modifier and Type | Method and Description |
---|---|
<R> CompletableFuture<R> |
FunctionalMap.ReadOnlyMap.eval(K key,
Function<EntryView.ReadEntryView<K,V>,R> f)
Evaluate a read-only function on the value associated with the key
and return a
CompletableFuture with the return type of the function. |
default <R> CompletableFuture<R> |
FunctionalMap.ReadOnlyMap.eval(K key,
SerializableFunction<EntryView.ReadEntryView<K,V>,R> f)
Same as
FunctionalMap.ReadOnlyMap.eval(Object, Function) except that the function must also
implement Serializable |
<R> Traversable<R> |
FunctionalMap.ReadOnlyMap.evalMany(Set<? extends K> keys,
Function<EntryView.ReadEntryView<K,V>,R> f)
Evaluate a read-only function on a key and potential value associated in
the functional map, for each of the keys in the set passed in, and
returns an
Traversable to work on each computed function's result. |
default <R> Traversable<R> |
FunctionalMap.ReadOnlyMap.evalMany(Set<? extends K> keys,
SerializableFunction<EntryView.ReadEntryView<K,V>,R> f)
Same as
FunctionalMap.ReadOnlyMap.evalMany(Set, Function) except that the function must also
implement Serializable |
AutoCloseable |
Listeners.ReadWriteListeners.onCreate(Consumer<EntryView.ReadEntryView<K,V>> f)
Add a create event specific listener by passing in a
Consumer to be called back each time a new cache entry is
created, passing in a EntryView.ReadEntryView of that new entry. |
AutoCloseable |
Listeners.ReadWriteListeners.onModify(BiConsumer<EntryView.ReadEntryView<K,V>,EntryView.ReadEntryView<K,V>> f)
Add a modify/update event specific listener by passing in a
BiConsumer to be called back each time an entry is
modified or updated, passing in a EntryView.ReadEntryView of the
previous entry as first parameter, and a EntryView.ReadEntryView of the
new value as second parameter. |
AutoCloseable |
Listeners.ReadWriteListeners.onModify(BiConsumer<EntryView.ReadEntryView<K,V>,EntryView.ReadEntryView<K,V>> f)
Add a modify/update event specific listener by passing in a
BiConsumer to be called back each time an entry is
modified or updated, passing in a EntryView.ReadEntryView of the
previous entry as first parameter, and a EntryView.ReadEntryView of the
new value as second parameter. |
AutoCloseable |
Listeners.ReadWriteListeners.onRemove(Consumer<EntryView.ReadEntryView<K,V>> f)
Add a remove event specific listener by passing in a
Consumer to be called back each time an entry is
removed, passing in the EntryView.ReadEntryView of the removed entry. |
AutoCloseable |
Listeners.WriteListeners.onWrite(Consumer<EntryView.ReadEntryView<K,V>> f)
Add a write event listener by passing in a
Consumer to be
called each time a cache entry is created, modified/updated or
removed. |
Modifier and Type | Interface and Description |
---|---|
static interface |
EntryViews.AccessLoggingReadWriteView<K,V> |
Modifier and Type | Method and Description |
---|---|
static <K,V> EntryView.ReadEntryView<K,V> |
EntryViews.noValue(Object key) |
static <K,V> EntryView.ReadEntryView<K,V> |
EntryViews.noValue(Object key,
DataConversion keyDataConversion) |
static <K,V> EntryView.ReadEntryView<K,V> |
EntryViews.readOnly(CacheEntry entry) |
static <K,V> EntryView.ReadEntryView<K,V> |
EntryViews.readOnly(CacheEntry<K,V> entry,
DataConversion keyDataConversion,
DataConversion valueDataConversion) |
static <K,V> EntryView.ReadEntryView<K,V> |
EntryViews.readOnly(K key,
V value,
Metadata metadata) |
Modifier and Type | Method and Description |
---|---|
Traversable<EntryView.ReadEntryView<K,V>> |
ReadOnlyMapImpl.entries() |
Modifier and Type | Method and Description |
---|---|
void |
FunctionalNotifier.notifyOnRemove(EntryView.ReadEntryView<K,V> removed)
Notify registered
ReadWriteListener instances of the removed
entry passing in the removed entry. |
void |
FunctionalNotifierImpl.notifyOnRemove(EntryView.ReadEntryView<K,V> removed) |
Modifier and Type | Method and Description |
---|---|
<R> CompletableFuture<R> |
ReadOnlyMapImpl.eval(K key,
Function<EntryView.ReadEntryView<K,V>,R> f) |
<R> Traversable<R> |
ReadOnlyMapImpl.evalMany(Set<? extends K> keys,
Function<EntryView.ReadEntryView<K,V>,R> f) |
AutoCloseable |
FunctionalNotifierImpl.onCreate(Consumer<EntryView.ReadEntryView<K,V>> f) |
AutoCloseable |
FunctionalNotifierImpl.onModify(BiConsumer<EntryView.ReadEntryView<K,V>,EntryView.ReadEntryView<K,V>> f) |
AutoCloseable |
FunctionalNotifierImpl.onModify(BiConsumer<EntryView.ReadEntryView<K,V>,EntryView.ReadEntryView<K,V>> f) |
AutoCloseable |
FunctionalNotifierImpl.onRemove(Consumer<EntryView.ReadEntryView<K,V>> f) |
AutoCloseable |
FunctionalNotifierImpl.onWrite(Consumer<EntryView.ReadEntryView<K,V>> f) |
Modifier and Type | Method and Description |
---|---|
static <K,V> Function<EntryView.ReadEntryView<K,V>,Boolean> |
MarshallableFunctions.returnReadOnlyFindIsPresent() |
static <K,V> Function<EntryView.ReadEntryView<K,V>,V> |
MarshallableFunctions.returnReadOnlyFindOrNull() |
Copyright © 2021 JBoss by Red Hat. All rights reserved.