composition

Documentation

Index

• func NewUseCases(authorizer app.RequestAuthorizer, ingress *queue.IngressQueue, ...) (*UseCases, *Services)
• type Services
• type UseCases

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
}