AssertRetentionSchedule creates a new queue retention tasks for the supplied queue, finished tasks matching the supplied parameters will be deleted.

AssertRetentionScheduleWithSpec ensures that a queue retention tasks exists with the provided task spec.

NewDequeuer creates a new postgres queue dequeuer.

NewDequeuerWithMetrics creates a new postgres queue dequeuer with the default metrics enabled.

NewQueuer creates a new postgres queue queuer.

NewQueuerWithMetrics creates a new postgres queue queuer with metrics enabled.

NewRetentionHandler creates a task handler that will clean up old finished tasks.

NewScheduler creates a new postgres task scheduler.

NewScheduler creates a new postgres task scheduler with metrics enabled.

SetupTables sets up all the necessary tables, foreign keys and indexes.

MaintenanceTaskQueue task queue name used for all the periodic maintenance jobs.

RetentionTask is finished task cleanup type.

SchedulesTable is the name of the Postgres table used for schedules.

TasksTable is the name of the Postgres table that is used for tasks.

ForeignReference describes a foreign key reference in the queue system.

RetentionTaskSpec defines a SQL task to remove completed tasks that match given criteria.