river

Documentation

Index

• type RiverJobs
  • func NewRiverJobs(pool *pgxpool.Pool, queuePrefix string) (*RiverJobs, error)
  • func (w *RiverJobs) AddJob(ctx context.Context, job jobs.Job) error
  • func (w *RiverJobs) AddJobType(jobFn jobs.JobFn) error
  • func (w *RiverJobs) AddJobs(ctx context.Context, jobs []jobs.Job) error
  • func (w *RiverJobs) AddQueue(queue string, count int) error
  • func (w *RiverJobs) RiverClient() *river.Client[pgx.Tx]
  • func (w *RiverJobs) Run(ctx context.Context) error
  • func (w *RiverJobs) RunJob(ctx context.Context, job jobs.Job) error
  • func (w *RiverJobs) Stop(ctx context.Context) error
  • func (w *RiverJobs) Use(mwf jobs.JobMiddleware)

Types

type RiverJobs

type RiverJobs struct {
	// contains filtered or unexported fields
}

func NewRiverJobs

func NewRiverJobs(pool *pgxpool.Pool, queuePrefix string) (*RiverJobs, error)

func (*RiverJobs) AddJob

func (w *RiverJobs) AddJob(ctx context.Context, job jobs.Job) error

func (*RiverJobs) AddJobType

func (w *RiverJobs) AddJobType(jobFn jobs.JobFn) error

func (*RiverJobs) AddJobs

func (w *RiverJobs) AddJobs(ctx context.Context, jobs []jobs.Job) error

func (*RiverJobs) AddQueue

func (w *RiverJobs) AddQueue(queue string, count int) error

func (*RiverJobs) RiverClient

func (w *RiverJobs) RiverClient() *river.Client[pgx.Tx]

func (*RiverJobs) Run

func (w *RiverJobs) Run(ctx context.Context) error

func (*RiverJobs) RunJob

func (w *RiverJobs) RunJob(ctx context.Context, job jobs.Job) error

func (*RiverJobs) Stop

func (w *RiverJobs) Stop(ctx context.Context) error

func (*RiverJobs) Use

func (w *RiverJobs) Use(mwf jobs.JobMiddleware)