package transports

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package replay

Type Members

  1. case class GrpcPermissionDeniedError(grpcError: GrpcError) extends PermissionDeniedError with Product with Serializable

    Supply the grpc error and specially tag permission denied issues

  2. class GrpcSequencerClientAuth extends FlagCloseable with NamedLogging

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

  3. class GrpcSequencerClientTransport extends SequencerClientTransport with NamedLogging
  4. class GrpcSequencerSubscription[E] extends SequencerSubscription[E] with NoTracing
    Annotations
    @VisibleForTesting()
  5. case class GrpcSubscriptionError(grpcError: GrpcError) extends SubscriptionError with Product with Serializable

    Supply the grpc error that caused the subscription to fail

  6. class GrpcSubscriptionErrorRetryPolicy extends CheckedSubscriptionErrorRetryPolicy[GrpcSubscriptionError] with NamedLogging
  7. case class GrpcSubscriptionUnexpectedException(exception: Throwable) extends SubscriptionError with Product with Serializable

    The GPRC subscription observer was called with an unexpected exception

  8. class HttpSequencerClientTransport extends SequencerClientTransport with NamedLogging
  9. class HttpSequencerSubscription[E] extends SequencerSubscription[E] with NoTracing

    Subscription to a sequencer over HTTP.

    Subscription to a sequencer over HTTP. Works by polling readNextEvent - if an event is found it will immediately try to read the next, otherwise it will delay for pollingInterval.

  10. sealed trait HttpSubscriptionError extends SubscriptionError
  11. class HttpSubscriptionErrorRetryPolicy extends CheckedSubscriptionErrorRetryPolicy[HttpSubscriptionError]
  12. trait SequencerClientTransport extends FlagCloseable with SupportsHandshake

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

  13. case class SubscriptionReadError(readError: HttpSequencerClientError) extends HttpSubscriptionError with Product with Serializable
  14. case class UnexpectedSubscriptionException(exception: Throwable) extends HttpSubscriptionError with Product with Serializable

Ungrouped