Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewUseCases ¶
func NewUseCases(authorizer app.RequestAuthorizer, ingress *queue.IngressQueue, egress *queue.EgressQueue, pending *pending.Registry, subscription_backpressure uint, ) (*UseCases, *Services)
Types ¶
type Services ¶
type Services struct {
SubscriptionsRegistry *subscription.Registry
RemoveSubscriptions *sub_service.RemoveSubscriptionsService
}
type UseCases ¶
type UseCases struct {
Publish publish.PublishMessage
Subscribe subscribe.SubscribeChannel
ReceiveData data.ReceiveData
Unsubscribe unsubscribe.UnsubscribeChannel
Shutdown shutdown.ShutdownConnection
}
Click to show internal directories.
Click to hide internal directories.