Package com.oracle.coherence.grpc.proxy

Class NamedCacheServiceGrpcImpl

java.lang.Object

com.oracle.coherence.grpc.NamedCacheServiceGrpc.NamedCacheServiceImplBase

com.oracle.coherence.grpc.proxy.NamedCacheServiceGrpcImpl

All Implemented Interfaces:

com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService, BindableGrpcProxyService, GrpcProxyService, io.grpc.BindableService

public class NamedCacheServiceGrpcImpl
extends com.oracle.coherence.grpc.NamedCacheServiceGrpc.NamedCacheServiceImplBase
implements BindableGrpcProxyService

A plain gRPC implementation of NamedCache service.

Author:

Jonathan Knight 2020.09.21

Constructor Summary

Constructors

Constructor	Description
NamedCacheServiceGrpcImpl()	Create a NamedCacheServiceGrpcImpl that wraps a default implementation of NamedCacheService.
NamedCacheServiceGrpcImpl(NamedCacheService service)	Create a NamedCacheServiceGrpcImpl with default configuration.
NamedCacheServiceGrpcImpl(NamedCacheService.Dependencies deps)	Create a NamedCacheServiceGrpcImpl that wraps a default implementation of NamedCacheService.

Method Summary

Modifier and Type	Method	Description
void	addIndex(com.oracle.coherence.grpc.AddIndexRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)
void	aggregate(com.oracle.coherence.grpc.AggregateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	clear(com.oracle.coherence.grpc.ClearRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)
void	containsEntry(com.oracle.coherence.grpc.ContainsEntryRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)
void	containsKey(com.oracle.coherence.grpc.ContainsKeyRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)
void	containsValue(com.oracle.coherence.grpc.ContainsValueRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)
void	destroy(com.oracle.coherence.grpc.DestroyRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)
void	entrySet(com.oracle.coherence.grpc.EntrySetRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer)
io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.MapListenerRequest>	events(io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.MapListenerResponse> observer)
void	get(com.oracle.coherence.grpc.GetRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.OptionalValue> observer)
void	getAll(com.oracle.coherence.grpc.GetAllRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer)
GrpcProxyMetrics	getMetrics()	Obtain the gRPC metrics instance for this service.
void	invoke(com.oracle.coherence.grpc.InvokeRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	invokeAll(com.oracle.coherence.grpc.InvokeAllRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer)
void	isEmpty(com.oracle.coherence.grpc.IsEmptyRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)
void	isReady(com.oracle.coherence.grpc.IsReadyRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)
void	keySet(com.oracle.coherence.grpc.KeySetRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	nextEntrySetPage(com.oracle.coherence.grpc.PageRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.EntryResult> observer)
void	nextKeySetPage(com.oracle.coherence.grpc.PageRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	put(com.oracle.coherence.grpc.PutRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	putAll(com.oracle.coherence.grpc.PutAllRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)
void	putIfAbsent(com.oracle.coherence.grpc.PutIfAbsentRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	remove(com.oracle.coherence.grpc.RemoveRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	removeIndex(com.oracle.coherence.grpc.RemoveIndexRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)
void	removeMapping(com.oracle.coherence.grpc.RemoveMappingRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)
void	replace(com.oracle.coherence.grpc.ReplaceRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)
void	replaceMapping(com.oracle.coherence.grpc.ReplaceMappingRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)
void	size(com.oracle.coherence.grpc.SizeRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Int32Value> observer)
void	truncate(com.oracle.coherence.grpc.TruncateRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)
void	values(com.oracle.coherence.grpc.ValuesRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Methods inherited from class com.oracle.coherence.grpc.NamedCacheServiceGrpc.NamedCacheServiceImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.grpc.BindableService

bindService

Constructor Detail

NamedCacheServiceGrpcImpl

public NamedCacheServiceGrpcImpl()

Create a NamedCacheServiceGrpcImpl that wraps a default implementation of NamedCacheService.

NamedCacheServiceGrpcImpl

public NamedCacheServiceGrpcImpl(NamedCacheService.Dependencies deps)

Create a NamedCacheServiceGrpcImpl that wraps a default implementation of NamedCacheService.

Parameters:

deps - the NamedCacheService.Dependencies to use

NamedCacheServiceGrpcImpl

public NamedCacheServiceGrpcImpl(NamedCacheService service)

Create a NamedCacheServiceGrpcImpl with default configuration.

Parameters:

service - the NamedCacheService to use

Method Detail

getMetrics

public GrpcProxyMetrics getMetrics()

Description copied from interface: GrpcProxyService

Obtain the gRPC metrics instance for this service.

Specified by:

getMetrics in interface GrpcProxyService

Returns:

the gRPC metrics instance for this service

addIndex

public void addIndex(com.oracle.coherence.grpc.AddIndexRequest request,
                     io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)

Specified by:

addIndex in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

aggregate

public void aggregate(com.oracle.coherence.grpc.AggregateRequest request,
                      io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

aggregate in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

clear

public void clear(com.oracle.coherence.grpc.ClearRequest request,
                  io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)

Specified by:

clear in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

containsEntry

public void containsEntry(com.oracle.coherence.grpc.ContainsEntryRequest request,
                          io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)

Specified by:

containsEntry in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

containsKey

public void containsKey(com.oracle.coherence.grpc.ContainsKeyRequest request,
                        io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)

Specified by:

containsKey in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

containsValue

public void containsValue(com.oracle.coherence.grpc.ContainsValueRequest request,
                          io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)

Specified by:

containsValue in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

destroy

public void destroy(com.oracle.coherence.grpc.DestroyRequest request,
                    io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)

Specified by:

destroy in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

entrySet

public void entrySet(com.oracle.coherence.grpc.EntrySetRequest request,
                     io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer)

Specified by:

entrySet in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

events

public io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.MapListenerRequest> events(io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.MapListenerResponse> observer)

Specified by:

events in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

get

public void get(com.oracle.coherence.grpc.GetRequest request,
                io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.OptionalValue> observer)

Specified by:

get in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

getAll

public void getAll(com.oracle.coherence.grpc.GetAllRequest request,
                   io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer)

Specified by:

getAll in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

invoke

public void invoke(com.oracle.coherence.grpc.InvokeRequest request,
                   io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

invoke in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

invokeAll

public void invokeAll(com.oracle.coherence.grpc.InvokeAllRequest request,
                      io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.Entry> observer)

Specified by:

invokeAll in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

isEmpty

public void isEmpty(com.oracle.coherence.grpc.IsEmptyRequest request,
                    io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)

Specified by:

isEmpty in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

isReady

public void isReady(com.oracle.coherence.grpc.IsReadyRequest request,
                    io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)

Specified by:

isReady in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

keySet

public void keySet(com.oracle.coherence.grpc.KeySetRequest request,
                   io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

keySet in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

nextEntrySetPage

public void nextEntrySetPage(com.oracle.coherence.grpc.PageRequest request,
                             io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.EntryResult> observer)

Specified by:

nextEntrySetPage in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

nextKeySetPage

public void nextKeySetPage(com.oracle.coherence.grpc.PageRequest request,
                           io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

nextKeySetPage in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

put

public void put(com.oracle.coherence.grpc.PutRequest request,
                io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

put in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

putAll

public void putAll(com.oracle.coherence.grpc.PutAllRequest request,
                   io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)

Specified by:

putAll in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

putIfAbsent

public void putIfAbsent(com.oracle.coherence.grpc.PutIfAbsentRequest request,
                        io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

putIfAbsent in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

remove

public void remove(com.oracle.coherence.grpc.RemoveRequest request,
                   io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

remove in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

removeIndex

public void removeIndex(com.oracle.coherence.grpc.RemoveIndexRequest request,
                        io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)

Specified by:

removeIndex in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

removeMapping

public void removeMapping(com.oracle.coherence.grpc.RemoveMappingRequest request,
                          io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)

Specified by:

removeMapping in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

replace

public void replace(com.oracle.coherence.grpc.ReplaceRequest request,
                    io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

replace in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

replaceMapping

public void replaceMapping(com.oracle.coherence.grpc.ReplaceMappingRequest request,
                           io.grpc.stub.StreamObserver<com.google.protobuf.BoolValue> observer)

Specified by:

replaceMapping in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

size

public void size(com.oracle.coherence.grpc.SizeRequest request,
                 io.grpc.stub.StreamObserver<com.google.protobuf.Int32Value> observer)

Specified by:

size in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

truncate

public void truncate(com.oracle.coherence.grpc.TruncateRequest request,
                     io.grpc.stub.StreamObserver<com.google.protobuf.Empty> observer)

Specified by:

truncate in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService

values

public void values(com.oracle.coherence.grpc.ValuesRequest request,
                   io.grpc.stub.StreamObserver<com.google.protobuf.BytesValue> observer)

Specified by:

values in interface com.oracle.coherence.grpc.NamedCacheServiceGrpc.AsyncService