Documentation
¶
Index ¶
- func ProcessPendingEmail(ctx context.Context, q db.Querier, provider email.Provider, ...) bool
- func ResolveQueuedEmailAddress(ctx context.Context, q db.Querier, cfg *config.RuntimeConfig, ...) (mail.Address, error)
- func StartEventListener(ctx context.Context, q db.Querier, provider email.Provider, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ProcessPendingEmail ¶
func ProcessPendingEmail(ctx context.Context, q db.Querier, provider email.Provider, dlqProvider dlq.DLQ, cfg *config.RuntimeConfig) bool
ProcessPendingEmail sends a single queued email if available.
func ResolveQueuedEmailAddress ¶
func ResolveQueuedEmailAddress(ctx context.Context, q db.Querier, cfg *config.RuntimeConfig, e *db.SystemListPendingEmailsRow) (mail.Address, error)
ResolveQueuedEmailAddress resolves the recipient for a queued email. When the user record is missing or lacks a valid address the admin or direct email logic is applied.
func StartEventListener ¶
func StartEventListener(ctx context.Context, q db.Querier, provider email.Provider, dlqProvider dlq.DLQ, bus *eventbus.Bus, cfg *config.RuntimeConfig)
StartEventListener listens for new messages queued by listening for EmailQueueEvent messages. It processes them immediately.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.