Documentation
¶
Index ¶
- type NotificationService
- func (s *NotificationService) CreateAdminSubscription(ctx context.Context, req *notificationproto.CreateAdminSubscriptionRequest) (*notificationproto.CreateAdminSubscriptionResponse, error)
- func (s *NotificationService) CreateSubscription(ctx context.Context, req *notificationproto.CreateSubscriptionRequest) (*notificationproto.CreateSubscriptionResponse, error)
- func (s *NotificationService) DeleteAdminSubscription(ctx context.Context, req *notificationproto.DeleteAdminSubscriptionRequest) (*notificationproto.DeleteAdminSubscriptionResponse, error)
- func (s *NotificationService) DeleteSubscription(ctx context.Context, req *notificationproto.DeleteSubscriptionRequest) (*notificationproto.DeleteSubscriptionResponse, error)
- func (s *NotificationService) DisableAdminSubscription(ctx context.Context, req *notificationproto.DisableAdminSubscriptionRequest) (*notificationproto.DisableAdminSubscriptionResponse, error)
- func (s *NotificationService) DisableSubscription(ctx context.Context, req *notificationproto.DisableSubscriptionRequest) (*notificationproto.DisableSubscriptionResponse, error)
- func (s *NotificationService) EnableAdminSubscription(ctx context.Context, req *notificationproto.EnableAdminSubscriptionRequest) (*notificationproto.EnableAdminSubscriptionResponse, error)
- func (s *NotificationService) EnableSubscription(ctx context.Context, req *notificationproto.EnableSubscriptionRequest) (*notificationproto.EnableSubscriptionResponse, error)
- func (s *NotificationService) GetAdminSubscription(ctx context.Context, req *notificationproto.GetAdminSubscriptionRequest) (*notificationproto.GetAdminSubscriptionResponse, error)
- func (s *NotificationService) GetSubscription(ctx context.Context, req *notificationproto.GetSubscriptionRequest) (*notificationproto.GetSubscriptionResponse, error)
- func (s *NotificationService) ListAdminSubscriptions(ctx context.Context, req *notificationproto.ListAdminSubscriptionsRequest) (*notificationproto.ListAdminSubscriptionsResponse, error)
- func (s *NotificationService) ListEnabledAdminSubscriptions(ctx context.Context, ...) (*notificationproto.ListEnabledAdminSubscriptionsResponse, error)
- func (s *NotificationService) ListEnabledSubscriptions(ctx context.Context, req *notificationproto.ListEnabledSubscriptionsRequest) (*notificationproto.ListEnabledSubscriptionsResponse, error)
- func (s *NotificationService) ListSubscriptions(ctx context.Context, req *notificationproto.ListSubscriptionsRequest) (*notificationproto.ListSubscriptionsResponse, error)
- func (s *NotificationService) Register(server *grpc.Server)
- func (s *NotificationService) UpdateAdminSubscription(ctx context.Context, req *notificationproto.UpdateAdminSubscriptionRequest) (*notificationproto.UpdateAdminSubscriptionResponse, error)
- func (s *NotificationService) UpdateSubscription(ctx context.Context, req *notificationproto.UpdateSubscriptionRequest) (*notificationproto.UpdateSubscriptionResponse, error)
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NotificationService ¶
type NotificationService struct {
// contains filtered or unexported fields
}
func NewNotificationService ¶
func NewNotificationService( mysqlClient mysql.Client, accountClient accountclient.Client, domainEventPublisher publisher.Publisher, opts ...Option, ) *NotificationService
func (*NotificationService) CreateAdminSubscription ¶
func (s *NotificationService) CreateAdminSubscription( ctx context.Context, req *notificationproto.CreateAdminSubscriptionRequest, ) (*notificationproto.CreateAdminSubscriptionResponse, error)
func (*NotificationService) CreateSubscription ¶
func (s *NotificationService) CreateSubscription( ctx context.Context, req *notificationproto.CreateSubscriptionRequest, ) (*notificationproto.CreateSubscriptionResponse, error)
func (*NotificationService) DeleteAdminSubscription ¶
func (s *NotificationService) DeleteAdminSubscription( ctx context.Context, req *notificationproto.DeleteAdminSubscriptionRequest, ) (*notificationproto.DeleteAdminSubscriptionResponse, error)
func (*NotificationService) DeleteSubscription ¶
func (s *NotificationService) DeleteSubscription( ctx context.Context, req *notificationproto.DeleteSubscriptionRequest, ) (*notificationproto.DeleteSubscriptionResponse, error)
func (*NotificationService) DisableAdminSubscription ¶
func (s *NotificationService) DisableAdminSubscription( ctx context.Context, req *notificationproto.DisableAdminSubscriptionRequest, ) (*notificationproto.DisableAdminSubscriptionResponse, error)
func (*NotificationService) DisableSubscription ¶
func (s *NotificationService) DisableSubscription( ctx context.Context, req *notificationproto.DisableSubscriptionRequest, ) (*notificationproto.DisableSubscriptionResponse, error)
func (*NotificationService) EnableAdminSubscription ¶
func (s *NotificationService) EnableAdminSubscription( ctx context.Context, req *notificationproto.EnableAdminSubscriptionRequest, ) (*notificationproto.EnableAdminSubscriptionResponse, error)
func (*NotificationService) EnableSubscription ¶
func (s *NotificationService) EnableSubscription( ctx context.Context, req *notificationproto.EnableSubscriptionRequest, ) (*notificationproto.EnableSubscriptionResponse, error)
func (*NotificationService) GetAdminSubscription ¶
func (s *NotificationService) GetAdminSubscription( ctx context.Context, req *notificationproto.GetAdminSubscriptionRequest, ) (*notificationproto.GetAdminSubscriptionResponse, error)
func (*NotificationService) GetSubscription ¶
func (s *NotificationService) GetSubscription( ctx context.Context, req *notificationproto.GetSubscriptionRequest, ) (*notificationproto.GetSubscriptionResponse, error)
func (*NotificationService) ListAdminSubscriptions ¶
func (s *NotificationService) ListAdminSubscriptions( ctx context.Context, req *notificationproto.ListAdminSubscriptionsRequest, ) (*notificationproto.ListAdminSubscriptionsResponse, error)
func (*NotificationService) ListEnabledAdminSubscriptions ¶
func (s *NotificationService) ListEnabledAdminSubscriptions( ctx context.Context, req *notificationproto.ListEnabledAdminSubscriptionsRequest, ) (*notificationproto.ListEnabledAdminSubscriptionsResponse, error)
func (*NotificationService) ListEnabledSubscriptions ¶
func (s *NotificationService) ListEnabledSubscriptions( ctx context.Context, req *notificationproto.ListEnabledSubscriptionsRequest, ) (*notificationproto.ListEnabledSubscriptionsResponse, error)
func (*NotificationService) ListSubscriptions ¶
func (s *NotificationService) ListSubscriptions( ctx context.Context, req *notificationproto.ListSubscriptionsRequest, ) (*notificationproto.ListSubscriptionsResponse, error)
func (*NotificationService) Register ¶
func (s *NotificationService) Register(server *grpc.Server)
func (*NotificationService) UpdateAdminSubscription ¶
func (s *NotificationService) UpdateAdminSubscription( ctx context.Context, req *notificationproto.UpdateAdminSubscriptionRequest, ) (*notificationproto.UpdateAdminSubscriptionResponse, error)
func (*NotificationService) UpdateSubscription ¶
func (s *NotificationService) UpdateSubscription( ctx context.Context, req *notificationproto.UpdateSubscriptionRequest, ) (*notificationproto.UpdateSubscriptionResponse, error)
Click to show internal directories.
Click to hide internal directories.