email

Documentation

Index

• Variables
• func FormatEmail(from string, to []string, subject string, body any) string
• func SendEmail(cli *smtp.Client, from string, to []string, subject, body string) error
• type EmailConsumer
  • 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
  • func NewEmailService(c *conf.EmailConfig) *EmailService
  • func (ms *EmailService) SendEmail(ctx context.Context, req *emailApi.SendEmailReq) (*emailApi.Empty, error)
• type SmtpPool
  • func NewSmtpPool(c *conf.SmtpConfig, max int) (*SmtpPool, error)
  • func (p *SmtpPool) Close()
  • func (p *SmtpPool) Get() (*smtp.Client, error)
  • func (p *SmtpPool) Put(cli *smtp.Client)
  • func (p *SmtpPool) SendEmail(to []string, subject, body string) error
  • func (p *SmtpPool) SetFrom(from string)

Variables

var ErrSmtpPoolClosed = fmt.Errorf("smtp pool closed")

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

ProviderSet is service providers.

Functions

func FormatEmail

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

func SendEmail

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

Types

type EmailConsumer

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

func NewEmailConsumer

func NewEmailConsumer(ms *EmailService) *EmailConsumer

func (*EmailConsumer) Cleanup

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

func (*EmailConsumer) ConsumeClaim

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

func (*EmailConsumer) Setup

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

type EmailService

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

func NewEmailService

func NewEmailService(c *conf.EmailConfig) *EmailService

func (*EmailService) SendEmail

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

type SmtpPool

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

func NewSmtpPool

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

func (*SmtpPool) Close

func (p *SmtpPool) Close()

func (*SmtpPool) Get

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

func (*SmtpPool) Put

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

func (*SmtpPool) SendEmail

func (p *SmtpPool) SendEmail(to []string, subject, body string) error

func (*SmtpPool) SetFrom

func (p *SmtpPool) SetFrom(from string)