Method JobGetAvailable

riverdriver/riversqlite/river_sqlite_driver.go:472–492

(ctx context.Context, params *riverdriver.JobGetAvailableParams)

`)

func (e *Executor) JobGetAvailable(ctx context.Context, params *riverdriver.JobGetAvailableParams) ([]*rivertype.JobRow, error) {
	ctx = sqlctemplate.WithReplacements(ctx, map[string]sqlctemplate.Replacement{
		"attempted_by_clause": {
			Stable: true, // input never changes
			Value:  jobGetAvailableAttemptedBySQL,
		},
	}, map[string]any{
		"attempted_by":     params.ClientID,
		"max_attempted_by": params.MaxAttemptedBy,
	})

	jobs, err := dbsqlc.New().JobGetAvailable(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.JobGetAvailableParams{
		MaxToLock: int64(params.MaxToLock),
		Now:       timeStringNullable(params.Now),
		Queue:     params.Queue,
	})
	if err != nil {
		return nil, interpretError(err)
	}
	return sliceutil.MapError(jobs, jobRowFromInternal)
}

func (e *Executor) JobGetByID(ctx context.Context, params *riverdriver.JobGetByIDParams) (*rivertype.JobRow, error) {
	job, err := dbsqlc.New().JobGetByID(schemaTemplateParam(ctx, params.Schema), e.dbtx, params.ID)