workqueue

Oct 10, 2026

Changes in this version

type Queue

+ func (q *Queue) CancelTx(ctx context.Context, tx pgx.Tx, ref contentref.ContentRef) (int, error)

Oct 2, 2026

Changes in this version

+ const PlaceQueue

type AudioArgs

+ Force bool

+ Preset string

+ type Families struct

+ Audio bool

+ Image bool

+ Video bool

+ func FamiliesOf(k *media.Kind, preset string) Families

type ImageArgs

+ Editor bool

+ Force bool

+ Preset string

+ type PlaceArgs struct

+ After int64

+ Force bool

+ Preset string

+ Ref contentref.ContentRef

+ func (PlaceArgs) Kind() string

+ func (a PlaceArgs) FollowUp(id int64) river.JobArgs

type VideoPlanArgs

+ Force bool

+ Preset string

Sep 25, 2026

Changes in this version

+ const VideoEncodeQueue

+ const VideoLightQueue

+ const VideoRiverMaxAttempts

+ func TenantBacklog(ctx context.Context, pool *pgxpool.Pool, schema string) (map[string]int64, error)

+ func VideoPlanInsertOpts(class media.VideoJobClass) *river.InsertOpts

+ type JobStatus struct

+ HighAttemptJobs int64

+ Jobs int64

+ OldestAvailableSeconds float64

+ Priority int

+ Queue string

+ State string

+ func Snapshot(ctx context.Context, pool *pgxpool.Pool, schema string) ([]JobStatus, error)

+ type VideoAssembleArgs struct

+ Ref contentref.ContentRef

+ RunID string

+ func (VideoAssembleArgs) Kind() string

+ type VideoChunkArgs struct

+ Index int

+ Ref contentref.ContentRef

+ RunID string

+ func (VideoChunkArgs) Kind() string

+ type VideoPlanArgs struct

+ Class media.VideoJobClass

+ Ref contentref.ContentRef

+ func (VideoPlanArgs) Kind() string

Sep 25, 2026

Changes in this version

+ const AudioQueue

+ var EncodeKinds = []string

+ func AudioInsertOpts() *river.InsertOpts

+ type AudioArgs struct

+ Ref contentref.ContentRef

+ func (AudioArgs) Kind() string

Sep 25, 2026

Changes in this version

+ func ValidSchema(schema string) error

type Queue

+ func (q *Queue) Schema() string

Sep 25, 2026

Changes in this version

+ const ImageQueue

+ const MaxAttempts

+ const Schema

+ const VideoQueue

+ func ClearProgress(ctx context.Context, pool *pgxpool.Pool, id int64) error

+ func Migrate(ctx context.Context, pool *pgxpool.Pool) error

+ func NewProgressSource(pool *pgxpool.Pool) media.ProgressSource

+ func RefMatch(ref contentref.ContentRef) ([]byte, *string, error)

+ func SetProgress(ctx context.Context, pool *pgxpool.Pool, id int64, ...) error

+ func VideoInsertOpts() *river.InsertOpts

+ type ImageArgs struct

+ After int64

+ Ref contentref.ContentRef

+ Slot string

+ func (ImageArgs) Kind() string

+ func (a ImageArgs) FollowUp(id int64) river.JobArgs

+ type Queue struct

+ func New(pool *pgxpool.Pool, kinds *media.Registry) (*Queue, error)

+ func (q *Queue) Cancel(ctx context.Context, ref contentref.ContentRef) (int, error)

+ func (q *Queue) Enqueue(ctx context.Context, job media.ProcessJob) error

+ func (q *Queue) EnqueueTx(ctx context.Context, tx pgx.Tx, job media.ProcessJob) error

+ type VideoArgs struct

+ Ref contentref.ContentRef

+ func (VideoArgs) Kind() string