import "code.pfad.fr/buchungssystem/internal/email"
func WriteTo(dst io.Writer, email database.Email, from mail.Address, hostname string) ([]string, error)
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(ctx context.Context, db *database.Queries, from mail.Address, resumeAfter time.Time, sendEmail func(from string, to []string, r io.Reader) error) (Queue, error)
Done returns a channel that's closed when the queue processing is stopped.