protected com.google.protobuf.Empty |
NamedCacheServiceImpl.addIndex(CacheRequestHolder<com.oracle.coherence.grpc.AddIndexRequest,Void> holder) |
Execute the AddIndexRequest request.
|
protected CompletionStage<com.google.protobuf.BytesValue> |
NamedCacheServiceImpl.aggregateWithFilter(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest,Void> holder) |
Execute the filtered AggregateRequest request.
|
protected CompletionStage<com.google.protobuf.BytesValue> |
NamedCacheServiceImpl.aggregateWithKeys(CacheRequestHolder<com.oracle.coherence.grpc.AggregateRequest,Void> holder) |
Execute the filtered AggregateRequest request.
|
protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest,Binary>> |
NamedCacheServiceImpl.containsEntry(CacheRequestHolder<com.oracle.coherence.grpc.ContainsEntryRequest,Void> holder) |
Execute the ContainsEntryRequest request and return a CompletionStage that will complete when
the AsyncNamedCache request completes and will contain a CacheRequestHolder
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) |
|
protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.ContainsValueRequest,Integer>> |
NamedCacheServiceImpl.containsValue(CacheRequestHolder<com.oracle.coherence.grpc.ContainsValueRequest,Void> holder) |
Execute the ContainsValueRequest request and return a CompletionStage that will complete when
the AsyncNamedCache request completes and will contain a CacheRequestHolder
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 a GetAllRequest 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 the EntrySetRequest request and send the results to the StreamObserver .
|
protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.GetRequest,Binary>> |
NamedCacheServiceImpl.get(CacheRequestHolder<com.oracle.coherence.grpc.GetRequest,Void> holder) |
|
protected Void |
NamedCacheServiceImpl.getAll(CacheRequestHolder<com.oracle.coherence.grpc.GetAllRequest,Void> holder,
io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer) |
Execute the GetAllRequest request and send the results to the StreamObserver .
|
protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest,Binary>> |
NamedCacheServiceImpl.invoke(CacheRequestHolder<com.oracle.coherence.grpc.InvokeRequest,Void> holder) |
|
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 filtered InvokeAllRequest request passing the results to the provided
StreamObserver .
|
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-based InvokeAllRequest request passing the results to the provided
StreamObserver .
|
protected Void |
NamedCacheServiceImpl.keySet(CacheRequestHolder<com.oracle.coherence.grpc.KeySetRequest,Void> holder,
io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer) |
Execute the key-based KeySetRequest request passing the results to the provided
StreamObserver .
|
protected CompletionStage<com.google.protobuf.Empty> |
NamedCacheServiceImpl.partitionedPutAll(CacheRequestHolder<com.oracle.coherence.grpc.PutAllRequest,Void> holder,
Map<Binary,Binary> map) |
Perform a putAll 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 a PutIfAbsentRequest request.
|
protected CompletableFuture<Binary> |
NamedCacheServiceImpl.remove(CacheRequestHolder<com.oracle.coherence.grpc.RemoveRequest,Void> holder) |
Execute a RemoveRequest request.
|
protected com.google.protobuf.Empty |
NamedCacheServiceImpl.removeIndex(CacheRequestHolder<com.oracle.coherence.grpc.RemoveIndexRequest,Void> holder) |
Execute the RemoveIndexRequest request.
|
protected CompletionStage<CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest,Boolean>> |
NamedCacheServiceImpl.removeMapping(CacheRequestHolder<com.oracle.coherence.grpc.RemoveMappingRequest,Void> holder) |
Execute the RemoveMappingRequest request and return a CompletionStage that will complete when
the AsyncNamedCache request completes and will contain a CacheRequestHolder
holding the result of the RemoveMappingRequest request as a serialized Boolean.
|
protected CompletableFuture<Binary> |
NamedCacheServiceImpl.replace(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceRequest,Void> holder) |
Execute a ReplaceRequest request.
|
protected CompletableFuture<Binary> |
NamedCacheServiceImpl.replaceMapping(CacheRequestHolder<com.oracle.coherence.grpc.ReplaceMappingRequest,Void> holder) |
Execute a ReplaceMappingRequest request.
|
protected Void |
NamedCacheServiceImpl.values(CacheRequestHolder<com.oracle.coherence.grpc.ValuesRequest,Void> holder,
io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer) |
Execute the ValuesRequest request passing the results to the provided
StreamObserver .
|