Documentation
¶
Index ¶
Constants ¶
View Source
const NotificationChannelSize = 100
NotificationChannelSize const
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NotificationController ¶
type NotificationController struct {
Logger log.ILogger
EventService event.IService
// contains filtered or unexported fields
}
NotificationController struct
func NewNotificationController ¶
func NewNotificationController(ctx context.Context, eventService event.IService, logger log.ILogger, queue rabbitmq.QueueClient) *NotificationController
NewNotificationController returns a pointer to a new NotificationController obj
func (*NotificationController) RegisterQueueHandler ¶
func (c *NotificationController) RegisterQueueHandler() chan notification.Notification
RegisterQueueHandler registers handler for the queue and returns channel of Notification
func (*NotificationController) Schedule ¶
func (c *NotificationController) Schedule() error
Schedule gets notifications and send they in queue
func (*NotificationController) Send ¶
func (c *NotificationController) Send(uq rabbitmq.QueueClient, n notification.Notification) error
Send is sends Notification obj
Source Files
Click to show internal directories.
Click to hide internal directories.