msgconsumer

package

v0.1.0-beta.0 Latest Latest Go to latest Published: Jun 25, 2020 License: MIT Imports: 4 Imported by: 0

Details

Package msgconsumer reads SMS/Email messages from Kafka.

This section is empty.

This section is empty.

This section is empty.

type ConfigOption func(*service) error

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 Kafka.

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

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.