- trait CloseNotification extends AnyRef
Allows instances to flag when they have actually closed.
Allows instances to flag when they have actually closed. Works around that FlagClosable only has one concurrent caller perform onClosed and other callers may not know when this has completed. TODO(#5705) This is overly complex and custom, revisit subscription pool closing
- class DirectSequencerSubscriptionFactory extends NamedLogging
Factory for creating resilient subscriptions directly to an in-process sequencer.Sequencer
- class GrpcEnterpriseSequencerAdministrationService extends EnterpriseSequencerAdministrationService with GrpcPruningScheduler with HasPruningScheduler
- trait GrpcHandshakeService extends AnyRef
- class GrpcSequencerAdministrationService extends SequencerAdministrationService
- class GrpcSequencerAuthenticationService extends SequencerAuthenticationService with NamedLogging
- class GrpcSequencerConnectService extends SequencerConnectService with GrpcHandshakeService with NamedLogging
Sequencer connect service on gRPC
- class GrpcSequencerInitializationService extends SequencerInitializationService with NamedLogging with NoTracing
Will initialize the sequencer server based using the provided initialize function when called.
- class GrpcSequencerService extends SequencerService with NamedLogging with FlagCloseable
Service providing a GRPC connection to the sequencer.Sequencer instance.
- class GrpcSequencerTopologyBootstrapService extends TopologyBootstrapService with NamedLogging
- class GrpcSequencerVersionService extends SequencerVersionService with GrpcHandshakeService with NamedLogging
- trait ManagedSubscription extends FlagCloseable with CloseNotification
Trait for the grpc managed subscription to allow easy testing without GRPC infrastructure
- class SubscriptionPool[Subscription <: ManagedSubscription] extends FlagCloseable with NamedLogging
Connects GRPC Sequencer subscriptions with subscriptions to the sequencer itself.
Connects GRPC Sequencer subscriptions with subscriptions to the sequencer itself. Ensures that when one side is closed that the other is. When the subscription manager is closed all active subscriptions and responses will be closed.
- object AuthenticationCheck
- object GrpcSequencerAuthenticationService extends GrpcSequencerAuthenticationErrorGroup
- object GrpcSequencerService
- object SubscriptionPool