controller

Documentation

Index

• Constants
• type NotificationController
  • func NewNotificationController(ctx context.Context, eventService event.IService, logger log.ILogger, ...) *NotificationController
  • func (c *NotificationController) RegisterQueueHandler() chan notification.Notification
  • func (c *NotificationController) Schedule() error
  • func (c *NotificationController) Send(uq rabbitmq.QueueClient, n notification.Notification) error

Constants

const NotificationChannelSize = 100

NotificationChannelSize const

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