postgres

Documentation

Index

• 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

Functions

func NewDequeuer

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

NewDequeuer creates a new postgres queue dequeuer

func NewDequeuerWithMetrics

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

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

func NewQueuer

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

NewQueuer creates a new postgres queue queuer

func NewQueuerWithMetrics

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

NewQueuerWithMetrics creates a new postgres queue queuer with metrics enabled

func NewScheduler

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

NewScheduler creates a new postgres task scheduler

func NewSchedulerWithMetrics

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

NewScheduler creates a new postgres task scheduler with metrics enabled

func Setup

func Setup(ctx context.Context, metricsNamespace string, db db.SQLDB, references []ForeignReference) error

Types

type ForeignReference

type ForeignReference struct {
	ColumnName       string
	ColumnType       string
	ReferencedTable  string
	ReferencedColumn string
}