email package

import "code.pfad.fr/buchungssystem/internal/email"

Index ¶

• func WriteTo(dst io.Writer, email database.Email, from mail.Address, hostname string) ([]string, error)
• type Queue
  • func NewQueue(ctx context.Context, db *database.Queries, from mail.Address, resumeAfter time.Time, sendEmail func(from string, to []string, r io.Reader) error) (Queue, error)
  • func (q Queue) DatabaseErrorf(format string, v ...interface{})
  • func (q Queue) Done() <-chan struct{}
  • func (q Queue) Push(ctx context.Context, email database.Email) error
  • func (q Queue) SendErrorf(format string, v ...interface{})

func WriteTo ¶

func WriteTo(dst io.Writer, email database.Email, from mail.Address, hostname string) ([]string, error)

type Queue ¶

type Queue struct {
	DB       *database.Queries
	SendMail func(from string, to []string, r io.Reader) error
	From     mail.Address
	Hostname string // Hostname is used for Message-Id
	// contains filtered or unexported fields
}

func NewQueue ¶

func NewQueue(ctx context.Context, db *database.Queries, from mail.Address, resumeAfter time.Time, sendEmail func(from string, to []string, r io.Reader) error) (Queue, error)

func (Queue) DatabaseErrorf ¶

func (q Queue) DatabaseErrorf(format string, v ...interface{})

func (Queue) Done ¶

func (q Queue) Done() <-chan struct{}

Done returns a channel that's closed when the queue processing is stopped.

func (Queue) Push ¶

func (q Queue) Push(ctx context.Context, email database.Email) error

func (Queue) SendErrorf ¶

func (q Queue) SendErrorf(format string, v ...interface{})

Source Files ¶

queue.go