Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TaskService ¶
type TaskService struct {
// contains filtered or unexported fields
}
func NewTaskService ¶
func NewTaskService(log *zap.SugaredLogger, db *db.DB, queue taskqueue.TaskQueue) *TaskService
func (*TaskService) DeleteTask ¶
func (s *TaskService) DeleteTask(ctx context.Context, task *taskqueue.TaskMessage) error
func (*TaskService) DeleteTasks ¶
func (s *TaskService) DeleteTasks(ctx context.Context, ids []string) error
func (*TaskService) GetTasks ¶
func (s *TaskService) GetTasks(ctx context.Context, opts *taskqueue.GetOptions) ([]*taskqueue.TaskMessage, error)
func (*TaskService) NotificationChannel ¶
func (s *TaskService) NotificationChannel() <-chan struct{}
func (*TaskService) Notify ¶
func (s *TaskService) Notify()
func (*TaskService) ScheduleAttempts ¶
func (s *TaskService) ScheduleAttempts(ctx context.Context, attempts []*entities.Attempt)
func (*TaskService) ScheduleTask ¶
Source Files
Click to show internal directories.
Click to hide internal directories.