Uses of Class
com.oracle.coherence.grpc.CacheRequestHolder
Packages that use CacheRequestHolder
Package
Description
Low-level utilities for Coherence gRPC server and client implementation.
The Netty based Coherence gRPC server implementation.
The Helidon based Coherence gRPC server implementation.
-
Uses of CacheRequestHolder in com.oracle.coherence.grpc
Methods in com.oracle.coherence.grpc that return types with arguments of type CacheRequestHolderModifier 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
Methods in com.oracle.coherence.grpc.proxy that return types with arguments of type CacheRequestHolderModifier and TypeMethodDescriptionprotected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest, Binary>> NettyNamedCacheService.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>> NettyNamedCacheService.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>> NettyNamedCacheService.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
<CacheRequestHolder<com.oracle.coherence.grpc.GetRequest, Binary>> NettyNamedCacheService.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>> NettyNamedCacheService.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>> NettyNamedCacheService.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.Methods in com.oracle.coherence.grpc.proxy with parameters of type CacheRequestHolderModifier and TypeMethodDescriptionprotected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest, Binary>> NettyNamedCacheService.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>> NettyNamedCacheService.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>> NettyNamedCacheService.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>> NettyNamedCacheService.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
NettyNamedCacheService.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>> NettyNamedCacheService.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
NettyNamedCacheService.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>> NettyNamedCacheService.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> NettyNamedCacheService.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> NettyNamedCacheService.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
NettyNamedCacheService.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.BytesValue> NettyNamedCacheService.put
(CacheRequestHolder<com.oracle.coherence.grpc.PutRequest, Void> holder) Execute a put request.protected CompletionStage
<com.google.protobuf.Empty> NettyNamedCacheService.putAll
(CacheRequestHolder<com.oracle.coherence.grpc.PutAllRequest, Void> holder) Execute a putAll request.protected CompletableFuture
<com.google.protobuf.BytesValue> NettyNamedCacheService.putIfAbsent
(CacheRequestHolder<com.oracle.coherence.grpc.PutIfAbsentRequest, Void> holder) Execute aPutIfAbsentRequest
request.protected CompletableFuture
<Binary> NettyNamedCacheService.remove
(CacheRequestHolder<com.oracle.coherence.grpc.RemoveRequest, Void> holder) Execute aRemoveRequest
request.protected CompletionStage
<CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Boolean>> NettyNamedCacheService.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> NettyNamedCacheService.replace
(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceRequest, Void> holder) Execute aReplaceRequest
request.protected CompletableFuture
<Binary> NettyNamedCacheService.replaceMapping
(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceMappingRequest, Void> holder) Execute aReplaceMappingRequest
request.protected Void
NettyNamedCacheService.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
. -
Uses of CacheRequestHolder in com.oracle.coherence.grpc.proxy.common
Fields in com.oracle.coherence.grpc.proxy.common declared as CacheRequestHolderModifier 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.Methods in com.oracle.coherence.grpc.proxy.common that return CacheRequestHolderModifier and TypeMethodDescription<Req> CacheRequestHolder
<Req, Void> BaseNamedCacheServiceImpl.createRequestHolder
(Req request, String sScope, String sCacheName, String format) Create aCacheRequestHolder
for a given request.<Req> CacheRequestHolder
<Req, Void> NamedCacheService.createRequestHolder
(Req request, String sScope, String sCacheName, String format) Create aCacheRequestHolder
for a given request.Methods in com.oracle.coherence.grpc.proxy.common that return types with arguments of type CacheRequestHolderModifier and TypeMethodDescription<Req> CompletionStage
<CacheRequestHolder<Req, Void>> BaseNamedCacheServiceImpl.createHolderAsync
(Req request, String sScope, String sCacheName, String format) Asynchronously create aCacheRequestHolder
for a given request.Methods in com.oracle.coherence.grpc.proxy.common with parameters of type CacheRequestHolderModifier and TypeMethodDescriptionprotected com.google.protobuf.Empty
BaseNamedCacheServiceImpl.addIndex
(CacheRequestHolder<com.oracle.coherence.grpc.AddIndexRequest, Void> holder) Execute theAddIndexRequest
request.protected CompletionStage
<com.google.protobuf.BytesValue> BaseNamedCacheServiceImpl.aggregateWithFilter
(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest, Void> holder, Executor executor) Execute the filteredAggregateRequest
request.protected CompletionStage
<com.google.protobuf.BytesValue> BaseNamedCacheServiceImpl.aggregateWithKeys
(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest, Void> holder, Executor executor) Execute the filteredAggregateRequest
request.BaseNamedCacheServiceImpl.convertKeysToBinary
(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.static Stream
<com.oracle.coherence.grpc.EntryResult> PagedQueryHelper.entryPagedQuery
(CacheRequestHolder<com.oracle.coherence.grpc.PageRequest, ?> holder, long cTransferThreshold) Perform a entry set paged query.static Stream
<com.google.protobuf.BytesValue> PagedQueryHelper.keysPagedQuery
(CacheRequestHolder<com.oracle.coherence.grpc.PageRequest, ?> holder, long cTransferThreshold) Perform a key set paged query.protected CompletionStage
<com.google.protobuf.Empty> BaseNamedCacheServiceImpl.partitionedPutAll
(CacheRequestHolder<com.oracle.coherence.grpc.PutAllRequest, Void> holder, Map<Binary, Binary> map) Perform aputAll
operation on a partitioned cache.protected com.google.protobuf.Empty
BaseNamedCacheServiceImpl.removeIndex
(CacheRequestHolder<com.oracle.coherence.grpc.RemoveIndexRequest, Void> holder) Execute theRemoveIndexRequest
request.Constructors in com.oracle.coherence.grpc.proxy.common with parameters of type CacheRequestHolderModifierConstructorDescriptionprotected
KeyConverter
(CacheRequestHolder<com.oracle.coherence.grpc.MapListenerRequest, Void> holder) Constructs a newKeyConverter
. -
Uses of CacheRequestHolder in com.oracle.coherence.grpc.proxy.helidon
Methods in com.oracle.coherence.grpc.proxy.helidon with parameters of type CacheRequestHolderModifier and TypeMethodDescriptionprotected void
HelidonNamedCacheService.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 void
HelidonNamedCacheService.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
.