Documentation
¶
Overview ¶
Package storages provides interfaces and implementations for task storage backends.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AdvancedTaskStorage ¶
type AdvancedTaskStorage interface {
Task
HardUpdateTask(ctx context.Context, taskID uuid.UUID, task *entity.Task) error
GetDB() *sqlx.DB
}
AdvancedTaskStorage is used only for tests.
type Task ¶
type Task interface {
AddTask(ctx context.Context, task *entity.Task) error
GetTask(ctx context.Context, id uuid.UUID) (*entity.Task, error)
GetTasks(ctx context.Context, filter *dbentity.GetTasksFilter, limit int64) ([]*entity.Task, error)
GetTasksForProcessing(ctx context.Context, taskType entity.TaskType, maxTasks int64) ([]*entity.Task, error)
UpdateTask(ctx context.Context, taskID uuid.UUID, task *entity.Task) error
DeleteTasks(ctx context.Context, taskType entity.TaskType, statuses []entity.TaskStatus, updatedAtTimeAgo time.Duration) ([]*entity.Task, error)
CureTasks(ctx context.Context, taskType entity.TaskType, unhealthStatuses []entity.TaskStatus, updatedAtTimeAgo time.Duration, comment string) ([]*entity.Task, error)
ResetAttempts(ctx context.Context, taskID uuid.UUID) error
}
Task defines the interface for task storage operations.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package dbentity provides common database entities and filters for task storage implementations.
|
Package dbentity provides common database entities and filters for task storage implementations. |
|
Package dbutils provides common database utilities for task storage implementations.
|
Package dbutils provides common database utilities for task storage implementations. |
|
mysql
|
|
|
task
Package mysqltask provides MySQL storage operations for task management in the queue system.
|
Package mysqltask provides MySQL storage operations for task management in the queue system. |
|
pg
|
|
|
task
Package task provides storage operations for task management in the queue system.
|
Package task provides storage operations for task management in the queue system. |
|
Package sqlite provides SQLite storage operations for task management in the queue system.
|
Package sqlite provides SQLite storage operations for task management in the queue system. |
Click to show internal directories.
Click to hide internal directories.