email

package

v0.3.2 Latest Latest Go to latest Published: Mar 14, 2024 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(
	NewEmailService,
	NewEmailConsumer,
)

ProviderSet is service providers.

func FormatMail(from string, to []string, subject, body any) string

func SendMail(cli *smtp.Client, from string, to []string, subject, body string) error

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

func NewEmailConsumer(ms *EmailService) *EmailConsumer

func (s *EmailConsumer) Cleanup(sarama.ConsumerGroupSession) error

func (s *EmailConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (s *EmailConsumer) Setup(sarama.ConsumerGroupSession) error

type EmailService struct {
	emailApi.UnimplementedEmailServer
	// contains filtered or unexported fields
}

func NewEmailService(c *conf.EmailConfig) *EmailService

func (ms *EmailService) SendEmail(ctx context.Context, req *emailApi.SendEmailReq) (*emailApi.Empty, error)

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

func NewSmtpPool(c *conf.SmtpConfig, max int) (*SmtpPool, error)

func (p *SmtpPool) Get() (*smtp.Client, error)

func (p *SmtpPool) Put(cli *smtp.Client)