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 aCompletionStagethat will complete with a value of aRequestHolderwith 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 theContainsEntryRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding 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 theContainsKeyRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding 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 theContainsValueRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding 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 theGetRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding the result of theGetRequestrequest as a serialized Boolean.protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest, Binary>> NettyNamedCacheService.invoke(CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest, Void> holder) Execute theInvokeRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding the result of theInvokeRequestrequest as a serialized Boolean.protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Boolean>> NettyNamedCacheService.removeMapping(CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Void> holder) Execute theRemoveMappingRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding the result of theRemoveMappingRequestrequest 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 theContainsEntryRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding 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 theContainsKeyRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding 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 theContainsValueRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding 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 aGetAllRequestfrom the request's serialization format to the cache's serialization format.protected VoidNettyNamedCacheService.entrySet(CacheRequestHolder<com.oracle.coherence.grpc.EntrySetRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute theEntrySetRequestrequest 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 theGetRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding the result of theGetRequestrequest as a serialized Boolean.protected VoidNettyNamedCacheService.getAll(CacheRequestHolder<com.oracle.coherence.grpc.GetAllRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute theGetAllRequestrequest 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 theInvokeRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding the result of theInvokeRequestrequest 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 filteredInvokeAllRequestrequest 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-basedInvokeAllRequestrequest passing the results to the providedStreamObserver.protected VoidNettyNamedCacheService.keySet(CacheRequestHolder<com.oracle.coherence.grpc.KeySetRequest, Void> holder, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer) Execute the key-basedKeySetRequestrequest 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 aPutIfAbsentRequestrequest.protected CompletableFuture<Binary> NettyNamedCacheService.remove(CacheRequestHolder<com.oracle.coherence.grpc.RemoveRequest, Void> holder) Execute aRemoveRequestrequest.protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Boolean>> NettyNamedCacheService.removeMapping(CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest, Void> holder) Execute theRemoveMappingRequestrequest and return aCompletionStagethat will complete when theAsyncNamedCacherequest completes and will contain aCacheRequestHolderholding the result of theRemoveMappingRequestrequest as a serialized Boolean.protected CompletableFuture<Binary> NettyNamedCacheService.replace(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceRequest, Void> holder) Execute aReplaceRequestrequest.protected CompletableFuture<Binary> NettyNamedCacheService.replaceMapping(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceMappingRequest, Void> holder) Execute aReplaceMappingRequestrequest.protected VoidNettyNamedCacheService.values(CacheRequestHolder<com.oracle.coherence.grpc.ValuesRequest, Void> holder, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer) Execute theValuesRequestrequest 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_holderCache request holder to handle conversion ofBinaryandByteStringobjects.protected CacheRequestHolder<com.oracle.coherence.grpc.MapListenerRequest, Void> MapListenerProxy.m_holderTheCacheRequestHolderto hold theMapListenerRequestthat 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 aCacheRequestHolderfor a given request.<Req> CacheRequestHolder<Req, Void> NamedCacheService.createRequestHolder(Req request, String sScope, String sCacheName, String format) Create aCacheRequestHolderfor 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 aCacheRequestHolderfor a given request.Methods in com.oracle.coherence.grpc.proxy.common with parameters of type CacheRequestHolderModifier and TypeMethodDescriptionprotected com.google.protobuf.EmptyBaseNamedCacheServiceImpl.addIndex(CacheRequestHolder<com.oracle.coherence.grpc.AddIndexRequest, Void> holder) Execute theAddIndexRequestrequest.protected CompletionStage<com.google.protobuf.BytesValue> BaseNamedCacheServiceImpl.aggregateWithFilter(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest, Void> holder, Executor executor) Execute the filteredAggregateRequestrequest.protected CompletionStage<com.google.protobuf.BytesValue> BaseNamedCacheServiceImpl.aggregateWithKeys(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest, Void> holder, Executor executor) Execute the filteredAggregateRequestrequest.BaseNamedCacheServiceImpl.convertKeysToBinary(CacheRequestHolder<com.oracle.coherence.grpc.GetAllRequest, Void> holder) Convert the keys for aGetAllRequestfrom 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 aputAlloperation on a partitioned cache.protected com.google.protobuf.EmptyBaseNamedCacheServiceImpl.removeIndex(CacheRequestHolder<com.oracle.coherence.grpc.RemoveIndexRequest, Void> holder) Execute theRemoveIndexRequestrequest.Constructors in com.oracle.coherence.grpc.proxy.common with parameters of type CacheRequestHolderModifierConstructorDescriptionprotectedKeyConverter(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 voidHelidonNamedCacheService.invokeAllWithFilter(CacheRequestHolder<com.oracle.coherence.grpc.InvokeAllRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute the filteredInvokeAllRequestrequest passing the results to the providedStreamObserver.protected voidHelidonNamedCacheService.invokeAllWithKeys(CacheRequestHolder<com.oracle.coherence.grpc.InvokeAllRequest, Void> holder, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) Execute the key-basedInvokeAllRequestrequest passing the results to the providedStreamObserver.