worker

Documentation

Index

• type EmailSender
  • func NewEmailSender(conf *common.Config) *EmailSender
  • func (e *EmailSender) SendEmail(to, subject, body string) (*mailersend.Response, error)
• type EmailSenderInterface
• type Worker
  • func NewWorker(emailSender *EmailSender, rmq *rabbitmq.RabbitMQBroker) *Worker
  • func (w *Worker) NotificationHandler(queue string, msg amqp.Delivery, err error)

Types

type EmailSender

type EmailSender struct {
	MailerSendServer *mailersend.Mailersend
	SenderName       string
	SenderEmail      string
}

func NewEmailSender

func NewEmailSender(conf *common.Config) *EmailSender

func (*EmailSender) SendEmail

func (e *EmailSender) SendEmail(to, subject, body string) (*mailersend.Response, error)

type EmailSenderInterface

type EmailSenderInterface interface {
	SendEmail(to, subject, body string) (*mailersend.Response, error)
}

type Worker

type Worker struct {
	EmailSender    EmailSenderInterface
	RabbitMQBroker rabbitmq.RabbitMQBrokerInterface
}

func NewWorker

func NewWorker(emailSender *EmailSender, rmq *rabbitmq.RabbitMQBroker) *Worker

func (*Worker) NotificationHandler

func (w *Worker) NotificationHandler(queue string, msg amqp.Delivery, err error)