notice_queue

Documentation

Index

• type ExternalNotificationQueueService
  • func NewNewQuestionNotificationQueueService() ExternalNotificationQueueService
• type NotificationQueueService
  • func NewNotificationQueueService() NotificationQueueService

Types

type ExternalNotificationQueueService

type ExternalNotificationQueueService interface {
	Send(ctx context.Context, msg *schema.ExternalNotificationMsg)
	RegisterHandler(handler func(ctx context.Context, msg *schema.ExternalNotificationMsg) error)
}

func NewNewQuestionNotificationQueueService

func NewNewQuestionNotificationQueueService() ExternalNotificationQueueService

NewNewQuestionNotificationQueueService create a new notification queue service

type NotificationQueueService

type NotificationQueueService interface {
	Send(ctx context.Context, msg *schema.NotificationMsg)
	RegisterHandler(handler func(ctx context.Context, msg *schema.NotificationMsg) error)
}

func NewNotificationQueueService

func NewNotificationQueueService() NotificationQueueService

NewNotificationQueueService create a new notification queue service