task

package

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

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ruko1202/goque

Links

Open Source Insights

Documentation ¶

Overview ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type GetTasksFilter ¶

type GetTasksFilter struct {
	TaskType         *entity.TaskType
	Status           *entity.TaskStatus
	UpdatedAtTimeAgo *time.Duration
}

GetTasksFilter defines filtering criteria for task queries.

type Storage ¶

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

Storage handles database operations for tasks.

func NewStorage ¶

func NewStorage(db *sqlx.DB) *Storage

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

func (*Storage) AddTask ¶

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

AddTask inserts a new task into the database.

func (*Storage) CureTasks ¶ added in v0.0.2

func (s *Storage) CureTasks(ctx context.Context, unhealthStatus entity.TaskStatus, updatedAtTimeAgo time.Duration, limit int64) ([]*entity.Task, error)

CureTasks marks stuck tasks in the specified unhealthy status as errored within a transaction.

func (*Storage) DeleteTasks ¶ added in v0.0.2

func (s *Storage) DeleteTasks(ctx context.Context, statuses []entity.TaskStatus, updatedAtTimeAgo time.Duration) ([]*entity.Task, error)

DeleteTasks removes tasks with specified statuses that haven't been updated within the given time period.

func (*Storage) GetTask ¶

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

GetTask retrieves a task from the database by its ID.

func (*Storage) GetTasks ¶

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 (*Storage) GetTasksForProcessing ¶

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 (*Storage) UpdateTask ¶

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL