Documentation
¶
Overview ¶
Package tasks provides background task implementations for the runner.
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).
type SessionCleanupTask ¶
type SessionCleanupTask struct {
// contains filtered or unexported fields
}
SessionCleanupTask cleans up expired sessions from the database.
func (*SessionCleanupTask) Name ¶
func (t *SessionCleanupTask) Name() string
Name returns the task name.
func (*SessionCleanupTask) Run ¶
func (t *SessionCleanupTask) Run(ctx context.Context) error
Run cleans up expired sessions.
func (*SessionCleanupTask) Schedule ¶
func (t *SessionCleanupTask) Schedule() string
Schedule returns the cron schedule based on configured interval.
func (*SessionCleanupTask) Timeout ¶
func (t *SessionCleanupTask) Timeout() time.Duration
Timeout returns the task timeout (2 minutes).
Source Files
Click to show internal directories.
Click to hide internal directories.