service

package

v0.9.0 Latest Latest Go to latest Published: Sep 29, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Options struct {
	DB        *db.DB
	TaskQueue taskqueue.TaskQueue
}

type Service struct {
	// contains filtered or unexported fields
}

func NewService(opts Options) *Service

func (s *Service) DeleteTask(ctx context.Context, task *taskqueue.TaskMessage) error

func (s *Service) GetTasks(ctx context.Context, opts *taskqueue.GetOptions) ([]*taskqueue.TaskMessage, error)

func (s *Service) ScheduleAttempts(ctx context.Context, attempts []*entities.Attempt)

func (s *Service) ScheduleTask(ctx context.Context, task *taskqueue.TaskMessage) error