Documentation
¶
Overview ¶
Package postgres provides the implementation of a tasq repository in PostgreSQL
Index ¶
- type Repository
- func (d *Repository) CleanTasks(ctx context.Context, cleanAge time.Duration) (int64, error)
- func (d *Repository) CountTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, ...) (int64, error)
- func (d *Repository) DeleteTask(ctx context.Context, task *tasq.Task, safeDelete bool) error
- func (d *Repository) Migrate(ctx context.Context) error
- func (d *Repository) PingTasks(ctx context.Context, taskIDs []uuid.UUID, visibilityTimeout time.Duration) ([]*tasq.Task, error)
- func (d *Repository) PollTasks(ctx context.Context, types, queues []string, visibilityTimeout time.Duration, ...) ([]*tasq.Task, error)
- func (d *Repository) PurgeTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, ...) (int64, error)
- func (d *Repository) RegisterError(ctx context.Context, task *tasq.Task, errTask error) (*tasq.Task, error)
- func (d *Repository) RegisterFinish(ctx context.Context, task *tasq.Task, finishStatus tasq.TaskStatus) (*tasq.Task, error)
- func (d *Repository) RegisterStart(ctx context.Context, task *tasq.Task) (*tasq.Task, error)
- func (d *Repository) RequeueTask(ctx context.Context, task *tasq.Task) (*tasq.Task, error)
- func (d *Repository) ScanTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, ...) ([]*tasq.Task, error)
- func (d *Repository) SubmitTask(ctx context.Context, task *tasq.Task) (*tasq.Task, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Repository ¶
type Repository struct {
// contains filtered or unexported fields
}
Repository implements the menthods necessary for tasq to work in PostgreSQL.
func NewRepository ¶
func NewRepository(dataSource any, prefix string) (*Repository, error)
NewRepository creates a new PostgreSQL Repository instance.
func (*Repository) CleanTasks ¶
CleanTasks removes finished tasks from the queue if their creation date is past the supplied duration.
func (*Repository) CountTasks ¶ added in v1.1.0
func (d *Repository) CountTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes, queues []string) (int64, error)
CountTasks returns the number of tasks in the queue based on the supplied filters.
func (*Repository) DeleteTask ¶
DeleteTask removes the supplied task from the queue.
func (*Repository) Migrate ¶
func (d *Repository) Migrate(ctx context.Context) error
Migrate prepares the database with the task status type and by adding the tasks table.
func (*Repository) PingTasks ¶
func (d *Repository) PingTasks(ctx context.Context, taskIDs []uuid.UUID, visibilityTimeout time.Duration) ([]*tasq.Task, error)
PingTasks pings a list of tasks by their ID and extends their invisibility timestamp with the supplied timeout parameter.
func (*Repository) PollTasks ¶
func (d *Repository) PollTasks(ctx context.Context, types, queues []string, visibilityTimeout time.Duration, ordering tasq.Ordering, pollLimit int) ([]*tasq.Task, error)
PollTasks polls for available tasks matching supplied the parameters and sets their invisibility the supplied timeout parameter to the future.
func (*Repository) PurgeTasks ¶ added in v1.1.0
func (d *Repository) PurgeTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes, queues []string, safeDelete bool) (int64, error)
PurgeTasks removes all tasks from the queue based on the supplied filters.
func (*Repository) RegisterError ¶
func (d *Repository) RegisterError(ctx context.Context, task *tasq.Task, errTask error) (*tasq.Task, error)
RegisterError records an error message on the task as last error.
func (*Repository) RegisterFinish ¶
func (d *Repository) RegisterFinish(ctx context.Context, task *tasq.Task, finishStatus tasq.TaskStatus) (*tasq.Task, error)
RegisterFinish marks a task as finished with the supplied status and records the time of finish.
func (*Repository) RegisterStart ¶
RegisterStart marks a task as started with the 'in progress' status and records the time of start.
func (*Repository) RequeueTask ¶
RequeueTask marks a task as new, so it can be picked up again.
func (*Repository) ScanTasks ¶ added in v1.1.0
func (d *Repository) ScanTasks(ctx context.Context, taskStatuses []tasq.TaskStatus, taskTypes, queues []string, ordering tasq.Ordering, scanLimit int) ([]*tasq.Task, error)
ScanTasks returns a list of tasks in the queue based on the supplied filters.
func (*Repository) SubmitTask ¶
SubmitTask adds the supplied task to the queue.
Source Files