riverx

Documentation

Index

• type JobArgs
  • func (ja JobArgs) Kind() string
• type Worker
  • func New(pool *pgxpool.Pool) *Worker
  • func (w *Worker) Work(ctx context.Context, job *river.Job[JobArgs]) error

Types

type JobArgs

type JobArgs struct {
	UserID uuid.UUID
}

func (JobArgs) Kind

func (ja JobArgs) Kind() string

Kind implements river.JobArgs.

type Worker

type Worker struct {
	river.WorkerDefaults[JobArgs]
	// contains filtered or unexported fields
}

func New

func New(pool *pgxpool.Pool) *Worker

func (*Worker) Work

func (w *Worker) Work(ctx context.Context, job *river.Job[JobArgs]) error

Work implements river.Worker.