Documentation
¶
Overview ¶
Package queue wires the River background job queue over PostgreSQL.
River runs in-process workers against the same database, using SELECT ... FOR UPDATE SKIP LOCKED. Job kinds (media processing, cleanup, delivery retry) are registered here as later milestones add them.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
Queue is the background job queue.
func New ¶
New creates a Queue over the given pool. Callers register their job workers on workers before calling New; an internal no-op worker is always registered so the client can start with an empty registry.
Source Files
Click to show internal directories.
Click to hide internal directories.