Type Members

1.  class ApiRequestLogger extends ApiRequestLoggerBase with ServerInterceptor with NamedLogging

   Server side interceptor that logs incoming and outgoing traffic.

2.  class ApiRequestLoggerBase extends NamedLogging

   Base class for building gRPC API request loggers.

   Base class for building gRPC API request loggers. Used in Canton network to build a client-side gRPC API request logger in addition to the server-side one.

   See https://github.com/DACH-NY/the-real-canton-coin/blob/bea9ccff84e72957aa7ac57ae3d1a00bc6d368d0/canton/community/common/src/main/scala/com/digitalasset/canton/networking/grpc/ApiClientRequestLogger.scala#L16

   Annotations

   @SuppressWarnings()

3.  class CantonCommunityServerInterceptors extends CantonServerInterceptors
4.  class CantonEnterpriseServerInterceptors extends CantonCommunityServerInterceptors
5.  trait CantonMutableHandlerRegistry extends AutoCloseable
6.  trait CantonServerBuilder extends AnyRef

   The io.grpc.ServerBuilder is pretty "loose" with its type parameters causing some issues for scalac and IntelliJ.

   The io.grpc.ServerBuilder is pretty "loose" with its type parameters causing some issues for scalac and IntelliJ. Here we provide a wrapper hiding these type issues.

7.  trait CantonServerInterceptors extends AnyRef
8.  trait ClientChannelBuilder extends AnyRef

   Construct a GRPC channel to be used by a client within canton.

9.  trait ClientChannelBuilderFactory extends (NamedLoggerFactory) => ClientChannelBuilder
10.  class CommunityClientChannelBuilder extends ClientChannelBuilder with NamedLogging with NoTracing

    Supports creating GRPC channels but only supports a single host.

    Supports creating GRPC channels but only supports a single host. If multiple endpoints are provided a warning will be logged and the first supplied will be used.

11.  class ConcurrencyLimitMetricsRegistry extends MetricRegistry with NamedLogging with NoTracing
12.  class EnterpriseClientChannelBuilder extends ClientChannelBuilder with NamedLogging

    CantonClientBuilder that supports using round-robin load balanced connections.

13.  abstract class ErrorLoggingStreamObserver[R] extends StreamObserver[R]
14.  class ForwardingStreamObserver[A, B] extends StreamObserver[A]

    Stream observer that will forward all received values, errors and completions to another observer, mapping values to a different type.

15.  class GrpcDynamicService extends NamedLogging

    Stand up a gRPC service stub which will direct to an instance set dynamically at runtime if available, or return a UNAVAILBLE status if not set.

    Stand up a gRPC service stub which will direct to an instance set dynamically at runtime if available, or return a UNAVAILBLE status if not set.

    Use setInstance and clear to update the backing service instance.

    There will be a performance penalty as the method on the backing service is looked up on each call, however this is likely fine for services that are rarely used like admin commands.

    Currently intentionally works with typeless io.grpc.ServiceDescriptor instances to allow use with stubs generated by StaticGrpcServices. Validation could be added to ensure full names of services and methods match.

16.  sealed trait GrpcError extends AnyRef
17.  class MultiHostNameResolver extends NameResolver

    A NameResolver that will perform DNS lookup for each of the provided hosts and aggregate the results into a single resolution result.

18.  class MultiHostNameResolverProvider extends NameResolverProvider
19.  class RecordingStreamObserver[RespT] extends StreamObserver[RespT]

    Stream observer that records all incoming events.