package transports
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- case class GrpcPermissionDeniedError(grpcError: GrpcError) extends PermissionDeniedError with Product with Serializable
Supply the grpc error and specially tag permission denied issues
- class GrpcSequencerClientAuth extends FlagCloseable with NamedLogging
Auth helpers for the GrpcSequencerClientTransport when dealing with our custom authentication tokens.
- class GrpcSequencerClientTransport extends SequencerClientTransport with NamedLogging
- class GrpcSequencerSubscription[E] extends SequencerSubscription[E] with NoTracing
- Annotations
- @VisibleForTesting()
- case class GrpcSubscriptionError(grpcError: GrpcError) extends SubscriptionError with Product with Serializable
Supply the grpc error that caused the subscription to fail
- class GrpcSubscriptionErrorRetryPolicy extends CheckedSubscriptionErrorRetryPolicy[GrpcSubscriptionError] with NamedLogging
- case class GrpcSubscriptionUnexpectedException(exception: Throwable) extends SubscriptionError with Product with Serializable
The GPRC subscription observer was called with an unexpected exception
- class HttpSequencerClientTransport extends SequencerClientTransport with NamedLogging
- 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 forpollingInterval
. - sealed trait HttpSubscriptionError extends SubscriptionError
- class HttpSubscriptionErrorRetryPolicy extends CheckedSubscriptionErrorRetryPolicy[HttpSubscriptionError]
- trait SequencerClientTransport extends FlagCloseable with SupportsHandshake
Implementation dependent operations for a client to read and write to a domain sequencer.
- case class SubscriptionReadError(readError: HttpSequencerClientError) extends HttpSubscriptionError with Product with Serializable
- case class UnexpectedSubscriptionException(exception: Throwable) extends HttpSubscriptionError with Product with Serializable
Value Members
- object GrpcSequencerSubscription
- object HttpSequencerSubscription