Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreateSubscriptionInput ¶
type CreateSubscriptionService ¶
type CreateSubscriptionService struct {
// contains filtered or unexported fields
}
func NewCreateSubscriptionService ¶
func NewCreateSubscriptionService(registry SubscribeRegistry, backpressure uint) *CreateSubscriptionService
func (*CreateSubscriptionService) Create ¶
func (service *CreateSubscriptionService) Create(input CreateSubscriptionInput) (*subscription.Subscription, error)
type FrameFactory ¶
type FrameFactory interface {
Unsubscribe() app.FrameBuilder
}
type RemoveSubscriptionsService ¶
type RemoveSubscriptionsService struct {
// contains filtered or unexported fields
}
func NewRemoveSubscriptionsService ¶
func NewRemoveSubscriptionsService(unsubscribe Unsubscriber) *RemoveSubscriptionsService
type SubscribeRegistry ¶
type SubscribeRegistry interface {
Register(*subscription.Subscription)
}
type Subscriptions ¶
type Subscriptions interface {
Active() []string
Get(string) *subscription.Subscription
}
type UnsubscribeRegistry ¶
type UnsubscribeRegistry interface {
Remove(id string)
Get(id string) *subscription.Subscription
}
type UnsubscribeService ¶
type UnsubscribeService struct {
// contains filtered or unexported fields
}
func NewUnsubscribeService ¶
func NewUnsubscribeService( subscriptions UnsubscribeRegistry, writer app.SendMessageService, authorizer app.RequestAuthorizer, frame FrameFactory, ) *UnsubscribeService
func (UnsubscribeService) Unsubscribe ¶
func (service UnsubscribeService) Unsubscribe(ctx context.Context, subscription_id string) error
Click to show internal directories.
Click to hide internal directories.