object CantonGrpcUtil

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CantonGrpcUtil
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. implicit final class GrpcFUSExtended[A] extends AnyVal

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def checkCantonApiInfo(serverName: String, expectedName: String, channel: ManagedChannel, logger: TracedLogger, timeout: NonNegativeDuration)(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[Future, String, Unit]
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. def invalidArgument(err: String): StatusRuntimeException
    Annotations
    @Deprecated
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. def mapErr[T, C](value: EitherT[Future, T, C])(implicit ec: ExecutionContext): EitherT[Future, StatusRuntimeException, C]
    Annotations
    @Deprecated
  14. def mapErr[T, C](value: Either[T, C])(implicit ec: ExecutionContext): EitherT[Future, StatusRuntimeException, C]
    Annotations
    @Deprecated
  15. def mapErrF[T, C](value: EitherT[Future, T, C])(implicit ec: ExecutionContext): Future[C]
    Annotations
    @Deprecated
  16. def mapErrNew[T <: CantonError, C](value: EitherT[Future, T, C])(implicit ec: ExecutionContext): Future[C]
  17. def mapErrNew[T <: BaseCantonError, C](value: EitherT[Future, T, C])(implicit executionContext: ExecutionContext, errorLoggingContext: ErrorLoggingContext): Future[C]
  18. def mapErrNew[T <: CantonError, C](value: Either[T, C])(implicit ec: ExecutionContext): EitherT[Future, StatusRuntimeException, C]
  19. def mapErrNewET[T <: CantonError, C](value: EitherT[Future, T, C])(implicit ec: ExecutionContext): EitherT[Future, StatusRuntimeException, C]
  20. def mapErrNewETUS[T <: CantonError, C](value: EitherT[FutureUnlessShutdown, T, C])(implicit ec: ExecutionContext, errorLoggingContext: ErrorLoggingContext): EitherT[Future, StatusRuntimeException, C]
  21. def mapErrNewEUS[T <: CantonError, C](value: EitherT[FutureUnlessShutdown, T, C])(implicit ec: ExecutionContext, errorLoggingContext: ErrorLoggingContext): Future[C]
  22. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  25. def retryUnlessClosing(closing: () => Boolean)(error: GrpcError): Boolean
  26. def sendGrpcRequest[Svc <: AbstractStub[Svc], Res](client: Svc, serverName: String)(send: (Svc) => Future[Res], requestDescription: String, timeout: Duration, logger: TracedLogger, logPolicy: (GrpcError) => (TracedLogger) => (TraceContext) => Unit = err => logger => traceContext => err.log(logger)(traceContext), retryPolicy: (GrpcError) => Boolean = _.retry)(implicit traceContext: TraceContext): EitherT[Future, GrpcError, Res]

    Wrapper method for sending a Grpc request.

    Wrapper method for sending a Grpc request. Takes care of appropriate logging and retrying.

    NOTE that this will NOT WORK for requests with streamed responses, as such requests will report errors to the corresponding io.grpc.stub.StreamObserver. You need to do error handling within the corresponding io.grpc.stub.StreamObserver.

    client

    the Grpc client used to send the request

    serverName

    used for logging

    send

    the client method for sending the request

    requestDescription

    used for logging

    timeout

    determines how long to retry or wait for a response. Will retry until 70% of this timeout has elapsed. Will wait for a response until this timeout has elapsed.

    logPolicy

    use this to configure log levels for errors

    retryPolicy

    invoked after an error to determine whether to retry

  27. def sendSingleGrpcRequest[Svc <: AbstractStub[Svc], Res](serverName: String, requestDescription: String, channel: ManagedChannel, stubFactory: (Channel) => Svc, timeout: Duration, logger: TracedLogger, logPolicy: (GrpcError) => (TracedLogger) => (TraceContext) => Unit = err => logger => traceContext => err.log(logger)(traceContext), retryPolicy: (GrpcError) => Boolean = _.retry)(send: (Svc) => Future[Res])(implicit traceContext: TraceContext): EitherT[Future, GrpcError, Res]

    Method to create a grpc channel and send a single request

    Method to create a grpc channel and send a single request

    Based on sendGrpcRequest

  28. val sequencerHealthCheckServiceName: String

    The name of the service that is associated with the sequencer servers' health status.

    The name of the service that is associated with the sequencer servers' health status. This name can have no relation with the gRPC services that the server is running with, and can be anything as long as the client and servers use the same value.

  29. def silentLogPolicy(error: GrpcError)(logger: TracedLogger)(traceContext: TraceContext): Unit
  30. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  31. def toString(): String
    Definition Classes
    AnyRef → Any
  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  34. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  35. def wrapErr[T](value: EitherT[Future, ProtoDeserializationError, T])(implicit loggingContext: ErrorLoggingContext, ec: ExecutionContext): EitherT[Future, CantonError, T]
  36. def wrapErr[T](value: ParsingResult[T])(implicit loggingContext: ErrorLoggingContext, ec: ExecutionContext): EitherT[Future, CantonError, T]
  37. object ApiName
  38. object GrpcErrors extends GrpcErrorGroup
  39. object RetryPolicy

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped