msgconsumer

package

v0.3.0 Latest Latest Go to latest Published: Jul 15, 2020 License: MIT Imports: 4 Imported by: 0

Details

Package msgconsumer reads and sends SMS/Email messages from a repository.

This section is empty.

This section is empty.

This section is empty.

type ConfigOption func(*service)

ConfigOption configures the service.

func WithLogger(l log.Logger) ConfigOption

WithLogger configures the service with a logger.

func WithWorkers(w int) ConfigOption

WithWorkers determines the total number of workers to process a message queue.

type Consumer interface {
	Run(ctx context.Context) error
}

Consumer reads a message stream from a repository.

func NewService(r auth.MessageRepository, smsLib SMSer, emailLib Emailer, options ...ConfigOption) Consumer

NewService returns a new Consumer

type Emailer interface {
	Email(ctx context.Context, email string, message string) error
}

Emailer exposes an API to send email messages.

type SMSer interface {
	SMS(ctx context.Context, phoneNumber string, message string) error
}

SMSer exposes an API to send SMS messages.