package transports
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- final 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 GrpcSequencerClientTransportCommon with SequencerClientTransport
- class GrpcSequencerClientTransportPekko extends GrpcSequencerClientTransport with SequencerClientTransportPekko
- class GrpcSequencerSubscription[E, R] extends SequencerSubscription[E] with NoTracing
- Annotations
- @VisibleForTesting()
- final 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
- class GrpcSubscriptionErrorRetryPolicyPekko extends SubscriptionErrorRetryPolicyPekko[GrpcSequencerSubscriptionError]
- final case class GrpcSubscriptionUnexpectedException(exception: Throwable) extends SubscriptionError with Product with Serializable
The GPRC subscription observer was called with an unexpected exception
- trait HasProtoTraceContext[R] extends AnyRef
- trait SequencerClientTransport extends SequencerClientTransportCommon
Implementation dependent operations for a client to read and write to a domain sequencer.
- trait SequencerClientTransportCommon extends FlagCloseable with SupportsHandshake
Implementation dependent operations for a client to write to a domain sequencer.
- trait SequencerClientTransportPekko extends SequencerClientTransportCommon
Implementation dependent operations for a client to read and write to a domain sequencer.
Value Members
- object GrpcSequencerClientTransportPekko
- object GrpcSequencerSubscription
- object GrpcSubscriptionErrorRetryPolicy
- object HasProtoTraceContext