Documentation
¶
Overview ¶
Package tasks provides background task implementations for the runner.
Index ¶
Constants ¶
View Source
const ( // MaxRetries is the maximum number of retry attempts for failed emails. MaxRetries = 5 // RetryDelayBase is the base delay for exponential backoff (in minutes). RetryDelayBase = 5 )
Variables ¶
This section is empty.
Functions ¶
func NewEmailQueueTask ¶
NewEmailQueueTask creates a new email queue task.
Types ¶
type EmailQueueTask ¶
type EmailQueueTask struct {
// contains filtered or unexported fields
}
EmailQueueTask processes emails from the mail queue.
func (*EmailQueueTask) Run ¶
func (t *EmailQueueTask) Run(ctx context.Context) error
Run processes pending emails from the queue.
func (*EmailQueueTask) Schedule ¶
func (t *EmailQueueTask) Schedule() string
Schedule returns the cron schedule (every 30 seconds).
func (*EmailQueueTask) Timeout ¶
func (t *EmailQueueTask) Timeout() time.Duration
Timeout returns the task timeout (5 minutes).
Source Files
Click to show internal directories.
Click to hide internal directories.