Versions in this module Expand all Collapse all v1 v1.0.1 Feb 6, 2026 Changes in this version + type TaskService struct + func NewTaskService(log *zap.SugaredLogger, db *db.DB, queue taskqueue.TaskQueue) *TaskService + func (s *TaskService) DeleteTask(ctx context.Context, task *taskqueue.TaskMessage) error + func (s *TaskService) DeleteTasks(ctx context.Context, ids []string) error + func (s *TaskService) GetTasks(ctx context.Context, opts *taskqueue.GetOptions) ([]*taskqueue.TaskMessage, error) + func (s *TaskService) NotificationChannel() <-chan struct{} + func (s *TaskService) Notify() + func (s *TaskService) ScheduleAttempts(ctx context.Context, attempts []*entities.Attempt) + func (s *TaskService) ScheduleTask(ctx context.Context, id string, scheduledAt time.Time) error
Go to main page