task

package

v0.0.0 Latest Latest Go to latest Published: Nov 28, 2025 License: MIT Imports: 10 Imported by: 0

Details

Package task provides storage operations for task management in the queue system.

This section is empty.

This section is empty.

This section is empty.

type GetTasksFilter struct {
	TaskType entity.TaskType
	Status   *entity.TaskStatus
}

GetTasksFilter defines filtering criteria for task queries.

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

Storage handles database operations for tasks.

func NewStorage(db *sqlx.DB) *Storage

NewStorage creates a new Storage instance with the provided database connection.

func (s *Storage) AddTask(ctx context.Context, task *entity.Task) error

AddTask inserts a new task into the database.

func (s *Storage) GetNewestTasks(ctx context.Context, filter *GetTasksFilter, limit int64) ([]*entity.Task, error)

GetNewestTasks retrieves tasks ordered by creation date (newest first) matching the filter.

func (s *Storage) GetOlderTasks(ctx context.Context, filter *GetTasksFilter, limit int64) ([]*entity.Task, error)

GetOlderTasks retrieves tasks ordered by creation date (oldest first) matching the filter.

func (s *Storage) GetTask(ctx context.Context, id uuid.UUID) (*entity.Task, error)

GetTask retrieves a task from the database by its ID.

func (s *Storage) GetTasks(ctx context.Context, filter *GetTasksFilter, limit int64) ([]*entity.Task, error)

GetTasks retrieves tasks matching the filter criteria with a specified limit.

func (s *Storage) GetTasksForProcessing(ctx context.Context, taskType entity.TaskType, limit int64) ([]*entity.Task, error)

GetTasksForProcessing retrieves and locks tasks ready for processing, updating their status to pending.

func (s *Storage) UpdateTask(ctx context.Context, taskID uuid.UUID, task *entity.Task) error

UpdateTask updates an existing task in the database with the provided data.