package transports

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package replay

Type Members

  1. abstract class ConsumesCancellableGrpcStreamObserver[E, R] extends SequencerSubscription[E]
  2. trait GrpcClientTransportHelpers extends AnyRef
  3. final case class GrpcPermissionDeniedError(grpcError: GrpcError) extends PermissionDeniedError with Product with Serializable

    Supply the grpc error and specially tag permission denied issues

  4. class GrpcSequencerClientAuth extends FlagCloseable with NamedLogging

    Auth helpers for the GrpcSequencerClientTransport when dealing with our custom authentication tokens.

  5. class GrpcSequencerClientTransport extends GrpcSequencerClientTransportCommon with SequencerClientTransport
  6. class GrpcSequencerClientTransportPekko extends GrpcSequencerClientTransport with SequencerClientTransportPekko
  7. class GrpcSequencerSubscription[E, R] extends ConsumesCancellableGrpcStreamObserver[E, R]
    Annotations
    @VisibleForTesting()
  8. final case class GrpcSubscriptionError(grpcError: GrpcError) extends SubscriptionError with Product with Serializable

    Supply the grpc error that caused the subscription to fail

  9. class GrpcSubscriptionErrorRetryPolicy extends CheckedSubscriptionErrorRetryPolicy[GrpcSubscriptionError] with NamedLogging
  10. class GrpcSubscriptionErrorRetryPolicyPekko extends SubscriptionErrorRetryPolicyPekko[GrpcSequencerSubscriptionError]
  11. final case class GrpcSubscriptionUnexpectedException(exception: Throwable) extends SubscriptionError with Product with Serializable

    The GPRC subscription observer was called with an unexpected exception

  12. trait HasProtoTraceContext[R] extends AnyRef
  13. trait SequencerClientTransport extends SequencerClientTransportCommon

    Implementation dependent operations for a client to read and write to a synchronizer sequencer.

  14. trait SequencerClientTransportCommon extends FlagCloseable

    Implementation dependent operations for a client to write to a synchronizer sequencer.

  15. trait SequencerClientTransportPekko extends SequencerClientTransportCommon

    Implementation dependent operations for a client to read and write to a synchronizer sequencer.

Ungrouped