postgres

Sep 1, 2020

Changes in this version

+ const SchedulesTable

+ const TasksTable

Jul 27, 2020

Changes in this version

+ func SetupTables(ctx context.Context, db db.SQLDB, references []ForeignReference) error

Jul 17, 2020

Changes in this version

+ func NewDequeuer(db *sql.DB, dbListener *pq.Listener, cfg config.Queue) queue.Dequeuer

+ func NewDequeuerWithMetrics(db *sql.DB, dbListener *pq.Listener, cfg config.Queue) queue.Dequeuer

+ func NewQueuer(db *sql.DB) queue.Queuer

+ func NewQueuerWithMetrics(db *sql.DB) queue.Queuer

+ func NewScheduler(db *sql.DB) queue.Scheduler

+ func NewSchedulerWithMetrics(db *sql.DB) queue.Scheduler

+ func Setup(ctx context.Context, metricsNamespace string, db db.SQLDB, ...) error

+ type ForeignReference struct

+ ColumnName string

+ ColumnType string

+ ReferencedColumn string

+ ReferencedTable string