Documentation
¶
Index ¶
- func AddWorker[T river.JobArgs](worker river.Worker[T])
- func Get(ctx context.Context, id int64) (*rivertype.JobRow, error)
- func GetAdminServer(ctx context.Context) (echo.MiddlewareFunc, error)
- func Insert(ctx context.Context, args river.JobArgs, opts *river.InsertOpts) (*rivertype.JobInsertResult, error)
- func RegisterPeriodicJob(p *river.PeriodicJob)
- func Shutdown()
- func Start(ctx context.Context) (err error)
- type AdditionalJobs
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAdminServer ¶
func GetAdminServer(ctx context.Context) (echo.MiddlewareFunc, error)
func Insert ¶
func Insert(ctx context.Context, args river.JobArgs, opts *river.InsertOpts) (*rivertype.JobInsertResult, error)
func RegisterPeriodicJob ¶
func RegisterPeriodicJob(p *river.PeriodicJob)
Types ¶
type AdditionalJobs ¶
type AdditionalJobs struct {
Jobs []int64
}
AdditionalJobs is the output format of a job that queues additional jobs when it is done. It allows tracking a series of jobs
func NewAdditionalJobs ¶
NewAdditionalJobs takes a list of job args, queues them all and returns an AdditionalJobs with their IDs
Source Files
Click to show internal directories.
Click to hide internal directories.