Package com.oracle.coherence.grpc.proxy.common
package com.oracle.coherence.grpc.proxy.common
-
ClassDescriptionA base class for gRPC services.The default
BaseGrpcServiceImpl.Dependencies
implementation.The dependencies to configure aBaseGrpcServiceImpl
.A base class for gRPCNamedCacheService
implementations.An interface implemented by bindable gRPC proxy services.A factory ofConfigurableCacheFactory
supplier functions that can return aConfigurableCacheFactory
for a given scope name.The defaultConfigurableCacheFactory
supplier.A fixedConfigurableCacheFactory
supplier that only supplies theConfigurableCacheFactory
instances provided when it was constructed.AnExecutor
that uses aDaemonPool
to execute tasks.Daemon pool metrics and management.A holder for gRPC connection metrics.A MBean to track gRPC connections.AServerInterceptor
that enables capturing of gRPC metrics.The gRPC Proxy metrics MBean implementation.The gRPC Proxy metrics MBean.An interface implemented by gRPC proxy services.A controller class that starts and stops the default gRPC server by responding toDefaultCacheServer
lifecycle events.A listener that will start the gRPC server base onCoherence
orDefaultCacheServer
lifecycle events.The dependencies for a gRPC bindable service.The defaultGrpcServiceDependencies
implementation.A class to encapsulate bidirectional streaming of map events for a single cache.NamedCacheDeactivationListener
that will communicate cache truncation and destruction events over the proxy.A holder for filter information.Converter for cache key instances.MapListenerSupport.PrimingListener
that delegates calls to the wrappedMapListener
.A NamedCache service.The defaultNamedCacheService.Dependencies
implementation.The dependencies to configure aNamedCacheService
.A plain gRPC implementation of NamedCache service.A helper class for cache key set and entry set paged queries.Helper methods to handle gRPC async responses.A gRPC server interceptor that will log messages on the server.ADaemonPool
implementation that wraps anotherDaemonPool
and adds activation of tracing spans for theRunnable
s executed by this pool.ARunnable
that executes another runnable after activating a tracing span.