queue

Documentation

Index

• Constants
• func NewQueueMux(emailHandler *EmailHandler) *asynq.ServeMux
• type Consumer
  • func NewQueueConsumer(redisAddr string) *Consumer
  • func (c *Consumer) Close()
  • func (c *Consumer) Run(mux *asynq.ServeMux) error
• type EmailHandler
  • func NewEmailHandler(mailerService *email.MailService) *EmailHandler
  • func (e *EmailHandler) SendEmailHandler(ctx context.Context, t *asynq.Task) error
• type EmailPayload
  • func (e *EmailPayload) Data() ([]byte, error)
• type Producer
  • func NewQueueProducer(redisAddr string) *Producer
  • func (p *Producer) Close() error
  • func (p *Producer) SendEmail(payload *EmailPayload) error

Constants

const (
	EmailQueue    = "emails"
	EmailSendTask = "email:send"
	MaxRetry      = 3
	TimeOut       = 30 * time.Second
)

Functions

func NewQueueMux

func NewQueueMux(
	emailHandler *EmailHandler,
) *asynq.ServeMux

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func NewQueueConsumer

func NewQueueConsumer(redisAddr string) *Consumer

func (*Consumer) Close

func (c *Consumer) Close()

func (*Consumer) Run

func (c *Consumer) Run(mux *asynq.ServeMux) error

type EmailHandler

type EmailHandler struct {
	// contains filtered or unexported fields
}

func NewEmailHandler

func NewEmailHandler(mailerService *email.MailService) *EmailHandler

func (*EmailHandler) SendEmailHandler

func (e *EmailHandler) SendEmailHandler(ctx context.Context, t *asynq.Task) error

type EmailPayload

type EmailPayload struct {
	To      string `json:"to"`
	Subject string `json:"subject"`
	Body    string `json:"body"`
}

func (*EmailPayload) Data

func (e *EmailPayload) Data() ([]byte, error)

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

func NewQueueProducer

func NewQueueProducer(redisAddr string) *Producer

func (*Producer) Close

func (p *Producer) Close() error

func (*Producer) SendEmail

func (p *Producer) SendEmail(payload *EmailPayload) error