mailqueue

Feb 9, 2026

Changes in this version

+ func BuildEmailMessage(from, to, subject, body string) []byte

+ func BuildEmailMessageWithHeaders(from, to, subject, body string, headers map[string]string) []byte

+ func BuildEmailMessageWithThreading(from, to, subject, body, domain string, inReplyTo, references string) []byte

+ func BuildHTMLEmailMessage(from, to, subject, htmlBody string) []byte

+ func BuildTextEmailMessage(from, to, subject, textBody string) []byte

+ func ExtractMessageIDFromRawMessage(rawMessage []byte) string

+ func GenerateMessageID(domain string) string

+ type MailQueueItem struct

+ ArticleID *int64

+ Attempts int

+ CreateTime time.Time

+ DueTime *time.Time

+ ID int64

+ InsertFingerprint *string

+ LastSMTPCode *int

+ LastSMTPMessage *string

+ RawMessage []byte

+ Recipient string

+ Sender *string

+ type MailQueueRepository struct

+ func NewMailQueueRepository(db *sql.DB) *MailQueueRepository

+ func (r *MailQueueRepository) Delete(ctx context.Context, id int64) error

+ func (r *MailQueueRepository) GetFailed(ctx context.Context, maxAttempts int, limit int) ([]*MailQueueItem, error)

+ func (r *MailQueueRepository) GetPending(ctx context.Context, limit int) ([]*MailQueueItem, error)

+ func (r *MailQueueRepository) Insert(ctx context.Context, item *MailQueueItem) error

+ func (r *MailQueueRepository) UpdateAttempts(ctx context.Context, id int64, smtpCode *int, smtpMessage *string, ...) error