Uses of Class
com.oracle.coherence.grpc.CacheRequestHolder
Package
Description
Low-level utilities for Coherence gRPC server and client implementation.
The Coherence gRPC server implementation.
-
Uses of CacheRequestHolder in com.oracle.coherence.grpc
Modifier and TypeMethodDescription<T> CompletionStage
<CacheRequestHolder<Req, T>> CacheRequestHolder.runAsync
(CompletionStage<T> stage) Return aCompletionStage
that will complete with a value of aRequestHolder
with a result value that is the result of the completion of the specifiedCompletionStage
. -
Uses of CacheRequestHolder in com.oracle.coherence.grpc.proxy
Modifier and TypeFieldDescriptionprotected final CacheRequestHolder
<com.oracle.coherence.grpc.MapListenerRequest, Void> MapListenerProxy.KeyConverter.f_holder
Cache request holder to handle conversion ofBinary
andByteString
objects.protected CacheRequestHolder
<com.oracle.coherence.grpc.MapListenerRequest, Void> MapListenerProxy.m_holder
TheCacheRequestHolder
to hold theMapListenerRequest
that can convert between different serialization formats.Modifier and TypeMethodDescription<Req> CacheRequestHolder
<Req, Void> NamedCacheService.createRequestHolder
(Req request, String sScope, String sCacheName, String format) Create aCacheRequestHolder
for a given request.<Req> CacheRequestHolder
<Req, Void> NamedCacheServiceImpl.createRequestHolder
(Req request, String sScope, String sCacheName, String format) Create aCacheRequestHolder
for a given request.Modifier and TypeMethodDescriptionprotected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest, Binary>> NamedCacheServiceImpl.containsEntry
(CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest, Void> holder) Execute theContainsEntryRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of the contains entry request as a serialized Boolean.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsKeyRequest, Boolean>> NamedCacheServiceImpl.containsKey
(CacheRequestHolder<com.oracle.coherence.grpc.ContainsKeyRequest, Void> holder) Execute theContainsKeyRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of the contains key request.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsValueRequest, Integer>> NamedCacheServiceImpl.containsValue
(CacheRequestHolder<com.oracle.coherence.grpc.ContainsValueRequest, Void> holder) Execute theContainsValueRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of the contains value request as a serialized Boolean.<Req> CompletionStage
<CacheRequestHolder<Req, Void>> NamedCacheServiceImpl.createHolderAsync
(Req request, String sScope, String sCacheName, String format) Asynchronously create aCacheRequestHolder
for a given request.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.GetRequest, Binary>> NamedCacheServiceImpl.get
(CacheRequestHolder<com.oracle.coherence.grpc.GetRequest, Void> holder) Execute theGetRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of theGetRequest
request as a serialized Boolean.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest, Binary>> NamedCacheServiceImpl.invoke
(CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest, Void> holder) Execute theInvokeRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of theInvokeRequest
request as a serialized Boolean.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Boolean>> NamedCacheServiceImpl.removeMapping
(CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Void> holder) Execute theRemoveMappingRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of theRemoveMappingRequest
request as a serialized Boolean.Modifier and TypeMethodDescriptionprotected com.google.protobuf.Empty
NamedCacheServiceImpl.addIndex
(CacheRequestHolder<com.oracle.coherence.grpc.AddIndexRequest, Void> holder) Execute theAddIndexRequest
request.protected CompletionStage
<com.google.protobuf.BytesValue> NamedCacheServiceImpl.aggregateWithFilter
(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest, Void> holder) Execute the filteredAggregateRequest
request.protected CompletionStage
<com.google.protobuf.BytesValue> NamedCacheServiceImpl.aggregateWithKeys
(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest, Void> holder) Execute the filteredAggregateRequest
request.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest, Binary>> NamedCacheServiceImpl.containsEntry
(CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest, Void> holder) Execute theContainsEntryRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of the contains entry request as a serialized Boolean.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsKeyRequest, Boolean>> NamedCacheServiceImpl.containsKey
(CacheRequestHolder<com.oracle.coherence.grpc.ContainsKeyRequest, Void> holder) Execute theContainsKeyRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of the contains key request.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsValueRequest, Integer>> NamedCacheServiceImpl.containsValue
(CacheRequestHolder<com.oracle.coherence.grpc.ContainsValueRequest, Void> holder) Execute theContainsValueRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of the contains value request as a serialized Boolean.protected CompletionStage
<List<Binary>> NamedCacheServiceImpl.convertKeys
(CacheRequestHolder<com.oracle.coherence.grpc.GetAllRequest, Void> holder) Convert the keys for aGetAllRequest
from the request's serialization format to the cache's serialization format.protected Void
NamedCacheServiceImpl.entrySet
(CacheRequestHolder<com.oracle.coherence.grpc.EntrySetRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute theEntrySetRequest
request and send the results to theStreamObserver
.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.GetRequest, Binary>> NamedCacheServiceImpl.get
(CacheRequestHolder<com.oracle.coherence.grpc.GetRequest, Void> holder) Execute theGetRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of theGetRequest
request as a serialized Boolean.protected Void
NamedCacheServiceImpl.getAll
(CacheRequestHolder<com.oracle.coherence.grpc.GetAllRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute theGetAllRequest
request and send the results to theStreamObserver
.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest, Binary>> NamedCacheServiceImpl.invoke
(CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest, Void> holder) Execute theInvokeRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of theInvokeRequest
request as a serialized Boolean.protected CompletionStage
<Void> NamedCacheServiceImpl.invokeAllWithFilter
(CacheRequestHolder<com.oracle.coherence.grpc.InvokeAllRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute the filteredInvokeAllRequest
request passing the results to the providedStreamObserver
.protected CompletionStage
<Void> NamedCacheServiceImpl.invokeAllWithKeys
(CacheRequestHolder<com.oracle.coherence.grpc.InvokeAllRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute the key-basedInvokeAllRequest
request passing the results to the providedStreamObserver
.protected Void
NamedCacheServiceImpl.keySet
(CacheRequestHolder<com.oracle.coherence.grpc.KeySetRequest, Void> holder, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer) Execute the key-basedKeySetRequest
request passing the results to the providedStreamObserver
.protected CompletionStage
<com.google.protobuf.Empty> NamedCacheServiceImpl.partitionedPutAll
(CacheRequestHolder<com.oracle.coherence.grpc.PutAllRequest, Void> holder, Map<Binary, Binary> map) Perform aputAll
operation on a partitioned cache.protected CompletionStage
<com.google.protobuf.BytesValue> NamedCacheServiceImpl.put
(CacheRequestHolder<com.oracle.coherence.grpc.PutRequest, Void> holder) Execute a put request.protected CompletionStage
<com.google.protobuf.Empty> NamedCacheServiceImpl.putAll
(CacheRequestHolder<com.oracle.coherence.grpc.PutAllRequest, Void> holder) Execute a putAll request.protected CompletableFuture
<com.google.protobuf.BytesValue> NamedCacheServiceImpl.putIfAbsent
(CacheRequestHolder<com.oracle.coherence.grpc.PutIfAbsentRequest, Void> holder) Execute aPutIfAbsentRequest
request.protected CompletableFuture
<Binary> NamedCacheServiceImpl.remove
(CacheRequestHolder<com.oracle.coherence.grpc.RemoveRequest, Void> holder) Execute aRemoveRequest
request.protected com.google.protobuf.Empty
NamedCacheServiceImpl.removeIndex
(CacheRequestHolder<com.oracle.coherence.grpc.RemoveIndexRequest, Void> holder) Execute theRemoveIndexRequest
request.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Boolean>> NamedCacheServiceImpl.removeMapping
(CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Void> holder) Execute theRemoveMappingRequest
request and return aCompletionStage
that will complete when theAsyncNamedCache
request completes and will contain aCacheRequestHolder
holding the result of theRemoveMappingRequest
request as a serialized Boolean.protected CompletableFuture
<Binary> NamedCacheServiceImpl.replace
(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceRequest, Void> holder) Execute aReplaceRequest
request.protected CompletableFuture
<Binary> NamedCacheServiceImpl.replaceMapping
(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceMappingRequest, Void> holder) Execute aReplaceMappingRequest
request.protected Void
NamedCacheServiceImpl.values
(CacheRequestHolder<com.oracle.coherence.grpc.ValuesRequest, Void> holder, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer) Execute theValuesRequest
request passing the results to the providedStreamObserver
.ModifierConstructorDescriptionprotected
KeyConverter
(CacheRequestHolder<com.oracle.coherence.grpc.MapListenerRequest, Void> holder) Constructs a newKeyConverter
.