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 Details

  • Method Details

    • 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